diff --git a/patching/workflow_1_initial.py b/patching/workflow_1_initial.py index 3be0ba28c..fffe517d2 100644 --- a/patching/workflow_1_initial.py +++ b/patching/workflow_1_initial.py @@ -12,7 +12,7 @@ class MyWorkflow: async def run(self) -> None: self._result = await workflow.execute_activity( pre_patch_activity, - schedule_to_close_timeout=timedelta(minutes=5), + start_to_close_timeout=timedelta(seconds=5), ) @workflow.query diff --git a/patching/workflow_2_patched.py b/patching/workflow_2_patched.py index f1e6bbae2..720456072 100644 --- a/patching/workflow_2_patched.py +++ b/patching/workflow_2_patched.py @@ -13,12 +13,12 @@ async def run(self) -> None: if workflow.patched("my-patch"): self._result = await workflow.execute_activity( post_patch_activity, - schedule_to_close_timeout=timedelta(minutes=5), + start_to_close_timeout=timedelta(seconds=5), ) else: self._result = await workflow.execute_activity( pre_patch_activity, - schedule_to_close_timeout=timedelta(minutes=5), + start_to_close_timeout=timedelta(seconds=5), ) @workflow.query diff --git a/patching/workflow_3_patch_deprecated.py b/patching/workflow_3_patch_deprecated.py index d226a47f2..116504df5 100644 --- a/patching/workflow_3_patch_deprecated.py +++ b/patching/workflow_3_patch_deprecated.py @@ -13,7 +13,7 @@ async def run(self) -> None: workflow.deprecate_patch("my-patch") self._result = await workflow.execute_activity( post_patch_activity, - schedule_to_close_timeout=timedelta(minutes=5), + start_to_close_timeout=timedelta(seconds=5), ) @workflow.query diff --git a/patching/workflow_4_patch_complete.py b/patching/workflow_4_patch_complete.py index 3a9e65958..1b8a82fdd 100644 --- a/patching/workflow_4_patch_complete.py +++ b/patching/workflow_4_patch_complete.py @@ -12,7 +12,7 @@ class MyWorkflow: async def run(self) -> None: self._result = await workflow.execute_activity( post_patch_activity, - schedule_to_close_timeout=timedelta(minutes=5), + start_to_close_timeout=timedelta(seconds=5), ) @workflow.query