File tree Expand file tree Collapse file tree 1 file changed +2
-0
lines changed Expand file tree Collapse file tree 1 file changed +2
-0
lines changed Original file line number Diff line number Diff line change @@ -358,6 +358,7 @@ def get_thread_id(self) -> Optional[int]:
358358 def activate (
359359 self , act : temporalio .bridge .proto .workflow_activation .WorkflowActivation
360360 ) -> temporalio .bridge .proto .workflow_completion .WorkflowActivationCompletion :
361+ print ("activate -------------------------------------------------------------" )
361362 # Reset current completion, time, and whether replaying
362363 self ._current_completion = (
363364 temporalio .bridge .proto .workflow_completion .WorkflowActivationCompletion ()
@@ -490,6 +491,7 @@ def is_completion(command):
490491 def _apply (
491492 self , job : temporalio .bridge .proto .workflow_activation .WorkflowActivationJob
492493 ) -> None :
494+ print ("job" , job .WhichOneof ("variant" ))
493495 if job .HasField ("cancel_workflow" ):
494496 self ._apply_cancel_workflow (job .cancel_workflow )
495497 elif job .HasField ("do_update" ):
You can’t perform that action at this time.
0 commit comments