From 7d68eaa3ac148d8c3884e68a6f365a24eed5f2f9 Mon Sep 17 00:00:00 2001
From: guillermo <guillermo@verdnatura.es>
Date: Mon, 11 Mar 2024 09:25:43 +0100
Subject: [PATCH] feat: refs #5846 Requested changes

---
 myt-push.js  | 16 ++++++++--------
 package.json |  2 +-
 2 files changed, 9 insertions(+), 9 deletions(-)

diff --git a/myt-push.js b/myt-push.js
index 77c3b9c..34a9a81 100644
--- a/myt-push.js
+++ b/myt-push.js
@@ -156,11 +156,19 @@ class Push extends Command {
             throw new Error(`Cannot obtain exclusive lock, used by connection ${isUsed}`);
         }
 
+        async function eventScheduler(isActive) {
+            await conn.query(
+                `SET GLOBAL event_scheduler = ${isActive ? 'ON' : 'OFF'}` 
+            );
+        }
+
         async function releaseLock() {
             await conn.query(`DO RELEASE_LOCK('myt_push')`);
+            await eventScheduler(true);
         }
 
         try {
+            await eventScheduler(false);
             await this.push(myt, opts, conn);
         } catch(err) {
             try {
@@ -225,7 +233,6 @@ class Push extends Command {
         // Apply versions
 
         this.emit('applyingVersions');
-        await this.eventScheduler(false);
 
         let nVersions = 0;
         let nChanges = 0;
@@ -343,7 +350,6 @@ class Push extends Command {
                 await conn.query('FLUSH PRIVILEGES');
                 await conn.query(`DROP TEMPORARY TABLE tProcsPriv`);
             }
-            await this.eventScheduler(true);
         }
 
         for (const change of changes)
@@ -535,12 +541,6 @@ class Push extends Command {
             return a.path.localeCompare(b.path);
         });
     }
-
-    async eventScheduler(isActive) {
-        await conn.query(
-            `SET GLOBAL event_scheduler = ${isActive ? 'ON' : 'OFF'}` 
-        );
-    }
 }
 
 const typeMap = {
diff --git a/package.json b/package.json
index ff7d358..8171d65 100644
--- a/package.json
+++ b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@verdnatura/myt",
-  "version": "1.6.8",
+  "version": "1.6.9",
   "author": "Verdnatura Levante SL",
   "description": "MySQL version control",
   "license": "GPL-3.0",