diff --git a/packages/local-sync/src/local-sync-worker/sync-worker.es6 b/packages/local-sync/src/local-sync-worker/sync-worker.es6 index b363bdbee..54f8d6a43 100644 --- a/packages/local-sync/src/local-sync-worker/sync-worker.es6 +++ b/packages/local-sync/src/local-sync-worker/sync-worker.es6 @@ -432,10 +432,11 @@ class SyncWorker { async interrupt({reason = 'No reason'} = {}) { console.log(`🔃 Interrupting sync! Reason: ${reason}`) - await this._interruptible.interrupt() + const interruptPromises = [await this._interruptible.interrupt()] if (this._currentTask) { - await this._currentTask.interrupt() + interruptPromises.push(this._currentTask.interrupt()) } + await Promise.all(interruptPromises) this._interrupted = true }