From 7279503ed7f7c5d10fa6d03a2859bbe481e29345 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Antonio=20Mendoza=20P=C3=A9rez?= Date: Thu, 28 Aug 2025 16:05:31 +0200 Subject: [PATCH] change patching to use start_to_close --- patching/workflow_1_initial.py | 2 +- patching/workflow_2_patched.py | 4 ++-- patching/workflow_3_patch_deprecated.py | 2 +- patching/workflow_4_patch_complete.py | 2 +- 4 files changed, 5 insertions(+), 5 deletions(-) diff --git a/patching/workflow_1_initial.py b/patching/workflow_1_initial.py index 3be0ba28..fffe517d 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 f1e6bbae..72045607 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 d226a47f..116504df 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 3a9e6595..1b8a82fd 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