fix

Signed-off-by: Deepanshu Agarwal <[email protected]>

examples/demo_workflow/README.md

@@ -69,6 +69,15 @@ You should be able to see the following output:
 == APP == New counter value is: 11!
 == APP == Retry count value is: 0!
 == APP == Retry count value is: 1! This print statement verifies retry
+== APP == Appending 1 to child_orchestrator_string!
+== APP == Appending a to child_orchestrator_string!
+== APP == Appending a to child_orchestrator_string!
+== APP == Appending 2 to child_orchestrator_string!
+== APP == Appending b to child_orchestrator_string!
+== APP == Appending b to child_orchestrator_string!
+== APP == Appending 3 to child_orchestrator_string!
+== APP == Appending c to child_orchestrator_string!
+== APP == Appending c to child_orchestrator_string!
 == APP == Get response from hello_world_wf after pause call: Suspended
 == APP == Get response from hello_world_wf after resume call: Running
 == APP == New counter value is: 111!

ext/dapr-ext-workflow/dapr/ext/workflow/dapr_workflow_context.py

@@ -63,10 +63,10 @@ def call_activity(self, activity: Callable[[WorkflowActivityContext, TInput], TO
                       retry_policy: Optional[RetryPolicy] = None) -> task.Task[TOutput]:
         self._logger.debug(f'{self.instance_id}: Creating activity {activity.__name__}')
         if hasattr(activity, '_dapr_alternate_name'):
-            act=activity.__dict__['_dapr_alternate_name']
+            act = activity.__dict__['_dapr_alternate_name']
         else:
             # this case should ideally never happen
-            act=activity.__name__
+            act = activity.__name__
         if retry_policy is None:
             return self.__obj.call_activity(activity=act, input=input)
         return self.__obj.call_activity(activity=act, input=input, retry_policy=retry_policy.obj)