fix status check

Author: icecrasher321

apps/sim/lib/core/workspace-dispatch/memory-store.ts

@@ -114,6 +114,8 @@ export class MemoryWorkspaceDispatchStorage implements WorkspaceDispatchStorageA
     return Array.from(this.jobs.values()).filter((record) => statuses.includes(record.status))
   }
 
+  private static readonly TERMINAL_STATUSES = new Set(['completed', 'failed'])
+
   async updateDispatchJobRecord(
     jobId: string,
     updater: (record: WorkspaceDispatchJobRecord) => WorkspaceDispatchJobRecord
@@ -124,6 +126,13 @@ export class MemoryWorkspaceDispatchStorage implements WorkspaceDispatchStorageA
     }
 
     const updated = updater(current)
+    if (
+      MemoryWorkspaceDispatchStorage.TERMINAL_STATUSES.has(current.status) &&
+      !MemoryWorkspaceDispatchStorage.TERMINAL_STATUSES.has(updated.status)
+    ) {
+      return current
+    }
+
     this.jobs.set(jobId, updated)
     return updated
   }

apps/sim/lib/core/workspace-dispatch/redis-store.ts

@@ -233,6 +233,8 @@ export class RedisWorkspaceDispatchStorage implements WorkspaceDispatchStorageAd
     return jobs
   }
 
+  private static readonly TERMINAL_STATUSES = new Set(['completed', 'failed'])
+
   async updateDispatchJobRecord(
     jobId: string,
     updater: (record: WorkspaceDispatchJobRecord) => WorkspaceDispatchJobRecord
@@ -243,6 +245,13 @@ export class RedisWorkspaceDispatchStorage implements WorkspaceDispatchStorageAd
     }
 
     const updated = updater(current)
+    if (
+      RedisWorkspaceDispatchStorage.TERMINAL_STATUSES.has(current.status) &&
+      !RedisWorkspaceDispatchStorage.TERMINAL_STATUSES.has(updated.status)
+    ) {
+      return current
+    }
+
     await this.saveDispatchJob(updated)
     return updated
   }