Keeps same api

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

Author: elena-kolevska

dapr/aio/clients/grpc/client.py

@@ -1501,6 +1501,9 @@ async def get_workflow(self, instance_id: str, workflow_component: str) -> GetWo
 
         try:
             resp = self._stub.GetWorkflowBeta1(req)
+            # not found workflows return no error, but empty status
+            if resp.runtime_status == '':
+                raise DaprInternalError('no such instance exists')
             if resp.created_at is None:
                 resp.created_at = datetime.now
             if resp.last_updated_at is None:

dapr/clients/grpc/client.py

@@ -1504,7 +1504,7 @@ def get_workflow(self, instance_id: str, workflow_component: str) -> GetWorkflow
             resp = self.retry_policy.run_rpc(self._stub.GetWorkflowBeta1, req)
             # not found workflows return no error, but empty status
             if resp.runtime_status == '':
-                return None
+                raise DaprInternalError('no such instance exists')
             if resp.created_at is None:
                 resp.created_at = datetime.now()
             if resp.last_updated_at is None:

examples/demo_workflow/app.py

@@ -205,11 +205,11 @@ def main():
         # Purge Test
         d.purge_workflow(instance_id=instance_id, workflow_component=workflow_component)
         sleep(5)
-        get_response = d.get_workflow(
-            instance_id=instance_id, workflow_component=workflow_component
-        )
-        if get_response is None:
-            print('Instance Successfully Purged')
+        try:
+            d.get_workflow(instance_id=instance_id, workflow_component=workflow_component)
+        except DaprInternalError as err:
+            if non_existent_id_error in err._message:
+                print('Instance Successfully Purged')
 
         workflow_runtime.shutdown()