chore(data-warehouse): don't raise if schedule already gone (#18978)

don't raise if schedule already gone
PostHog · Nov 30, 2023 · e7ba706 · e7ba706
1 parent 4da5395
commit e7ba706
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/posthog/warehouse/data_load/service.py b/posthog/warehouse/data_load/service.py
@@ -25,6 +25,7 @@
     ExternalDataJobWorkflow,
 )
 from posthog.warehouse.models import ExternalDataSource
+import temporalio
 
 
 def sync_external_data_job_workflow(external_data_source: ExternalDataSource, create: bool = False) -> str:
@@ -66,4 +67,10 @@ def pause_external_data_workflow(external_data_source: ExternalDataSource):
 
 def delete_external_data_workflow(external_data_source: ExternalDataSource):
     temporal = sync_connect()
-    delete_schedule(temporal, schedule_id=str(external_data_source.id))
+    try:
+        delete_schedule(temporal, schedule_id=str(external_data_source.id))
+    except temporalio.service.RPCError as e:
+        # Swallow error if schedule does not exist already
+        if e.status == temporalio.service.RPCStatusCode.NOT_FOUND:
+            return
+        raise