Add error handling around Temporal client operations.

TogetherCrew · Nov 16, 2024 · 4fd85fd · 4fd85fd
1 parent e45f4da
commit 4fd85fd
Showing 1 changed file with 21 additions and 18 deletions.
diff --git a/src/services/temporal/discourse.service.ts b/src/services/temporal/discourse.service.ts
@@ -4,24 +4,27 @@ import config from '../../config';
 
 class TemporalDiscourseService extends TemporalCoreService {
   public async createSchedule(platformId: string, endpoint: string): Promise<ScheduleHandle> {
-    const client: Client = await this.getClient();
-
-    return client.schedule.create({
-      action: {
-        type: 'startWorkflow',
-        workflowType: 'DiscourseExtractWorkflow',
-        args: [endpoint], // TODO add platformId
-        taskQueue: config.temporal.heavyQueue,
-      },
-      scheduleId: `discourse/${encodeURIComponent(endpoint)}`,
-      policies: {
-        catchupWindow: '1 day',
-        overlap: ScheduleOverlapPolicy.SKIP,
-      },
-      spec: {
-        intervals: [{ every: '1d' }],
-      },
-    });
+    try {
+      const client: Client = await this.getClient();
+      return client.schedule.create({
+        action: {
+          type: 'startWorkflow',
+          workflowType: 'DiscourseExtractWorkflow',
+          args: [endpoint], // TODO add platformId
+          taskQueue: config.temporal.heavyQueue,
+        },
+        scheduleId: `discourse/${encodeURIComponent(endpoint)}`,
+        policies: {
+          catchupWindow: '1 day',
+          overlap: ScheduleOverlapPolicy.SKIP,
+        },
+        spec: {
+          intervals: [{ every: '1d' }],
+        },
+      });
+    } catch (error) {
+      throw new Error(`Failed to create Temporal schedule: ${(error as Error).message}`);
+    }
   }
 }