Catch error in sdk when workflow instance not found

Signed-off-by: Elena Kolevska <[email protected]>

Author: elena-kolevska

examples/workflow/monitor.py

@@ -63,11 +63,7 @@ def send_alert(ctx, message: str):
 
     wf_client = wf.DaprWorkflowClient()
     job_id = 'job1'
-    status = None
-    try:
-        status = wf_client.get_workflow_state(job_id)
-    except Exception:
-        pass
+    status = wf_client.get_workflow_state(job_id)
     if not status or status.runtime_status.name != 'RUNNING':
         # TODO update to use reuse_id_policy
         instance_id = wf_client.schedule_new_workflow(

ext/dapr-ext-workflow/dapr/ext/workflow/dapr_workflow_client.py

@@ -130,8 +130,12 @@ def get_workflow_state(
             exist.
 
         """
-        state = self.__obj.get_orchestration_state(instance_id, fetch_payloads=fetch_payloads)
-        return WorkflowState(state) if state else None
+        try:
+            state = self.__obj.get_orchestration_state(instance_id, fetch_payloads=fetch_payloads)
+            return WorkflowState(state) if state else None
+        except Exception as error:
+            self._logger.error(f'Error fetching workflow state: {error}')
+            return None
 
     def wait_for_workflow_start(
         self, instance_id: str, *, fetch_payloads: bool = False, timeout_in_seconds: int = 60