Merge pull request #2 from acroca/updates-protos

Fix legacy demo_workflow example

Author: elena-kolevska

dapr/clients/grpc/client.py

@@ -1502,6 +1502,9 @@ def get_workflow(self, instance_id: str, workflow_component: str) -> GetWorkflow
 
         try:
             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
             if resp.created_at is None:
                 resp.created_at = datetime.now()
             if resp.last_updated_at is None:

examples/demo_workflow/README.md

@@ -49,11 +49,11 @@ expected_stdout_lines:
   - "== APP == Get response from hello_world_wf after resume call: Running"
   - "== APP == New counter value is: 111!"
   - "== APP == New counter value is: 1111!"
-  - "== APP == Instance Successfully Purged"
   - "== APP == Get response from hello_world_wf after terminate call: Terminated"
   - "== APP == Get response from child_wf after terminate call: Terminated"
+  - "== APP == Instance Successfully Purged"
 background: true
-timeout_seconds: 30
+timeout_seconds: 50
 sleep: 15
 -->
 
@@ -83,7 +83,7 @@ You should be able to see the following output:
 == APP == Get response from hello_world_wf after resume call: Running
 == APP == New counter value is: 111!
 == APP == New counter value is: 1111!
-== APP == Instance Successfully Purged
 == APP == Get response from hello_world_wf after terminate call: Terminated
 == APP == Get response from child_wf after terminate call: Terminated
+== APP == Instance Successfully Purged
 ```

examples/demo_workflow/app.py

@@ -205,11 +205,9 @@ def main():
         # Purge Test
         d.purge_workflow(instance_id=instance_id, workflow_component=workflow_component)
         sleep(5)
-        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')
+        get_response = d.get_workflow(instance_id=instance_id, workflow_component=workflow_component)
+        if get_response is None:
+            print('Instance Successfully Purged')
 
         workflow_runtime.shutdown()