Use if/else instead of return so finally executes

beethovenxfi · Sep 4, 2023 · 2373af2 · 2373af2
1 parent 71731f4
commit 2373af2
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/worker/job-queue.ts b/worker/job-queue.ts
@@ -10,9 +10,10 @@ class WokerQueue {
     public async sendWithInterval(json: string, intervalMs: number, deDuplicationId?: string): Promise<void> {
         try {
             if (env.WORKER_QUEUE_URL.match(/localhost/)) {
-                return this.sendLocalMessage(json );
+                await this.sendLocalMessage(json );
+            } else {
+                await this.sendMessage(json, deDuplicationId);
             }
-            await this.sendMessage(json, deDuplicationId);
             console.log(`Sent message to schedule job on queue ${env.WORKER_QUEUE_URL}: ${json}`);
         } catch (error) {
             console.log(error);