Add a missing await in acquireLeases

lifion · Jul 9, 2019 · 62e21f6 · 62e21f6
1 parent 4de1f51
commit 62e21f6
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/lease-manager.js b/lib/lease-manager.js
@@ -226,7 +226,7 @@ class LeaseManager {
       const changesDetected = (await Object.keys(shards).reduce(async (result, id) => {
         return (await result).concat(await acquireLease(this, id, shards));
       }, [])).some(Boolean);
-      if (changesDetected) consumersManager.reconcile();
+      if (changesDetected) await consumersManager.reconcile();
 
       privateProps.timeoutId = setTimeout(acquireLeases, ACQUIRE_LEASES_INTERVAL);
     };