diff --git a/src/services/sql.js b/src/services/sql.js
index 299729348..9e00168c5 100644
--- a/src/services/sql.js
+++ b/src/services/sql.js
@@ -209,6 +209,8 @@ async function transactional(func) {
 
             transactionActive = false;
             resolve();
+
+            setTimeout(() => require('./ws').sendPingToAllClients(), 50);
         }
         catch (e) {
             if (transactionActive) {
diff --git a/src/services/sync_table.js b/src/services/sync_table.js
index c96cf2ba0..4ed4abcff 100644
--- a/src/services/sync_table.js
+++ b/src/services/sync_table.js
@@ -24,8 +24,6 @@ async function addEntitySync(entityName, entityId, sourceId) {
     const sync = await insertEntitySync(entityName, entityId, sourceId);
 
     syncs.push(sync);
-
-    setTimeout(() => require('./ws').sendPingToAllClients(), 50);
 }
 
 async function addEntitySyncsForSector(entityName, entityPrimaryKey, sector) {