Skip to content

Commit 7279503

Browse files
committed
change patching to use start_to_close
1 parent 0cae313 commit 7279503

4 files changed

Lines changed: 5 additions & 5 deletions

File tree

patching/workflow_1_initial.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@ class MyWorkflow:
1212
async def run(self) -> None:
1313
self._result = await workflow.execute_activity(
1414
pre_patch_activity,
15-
schedule_to_close_timeout=timedelta(minutes=5),
15+
start_to_close_timeout=timedelta(seconds=5),
1616
)
1717

1818
@workflow.query

patching/workflow_2_patched.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -13,12 +13,12 @@ async def run(self) -> None:
1313
if workflow.patched("my-patch"):
1414
self._result = await workflow.execute_activity(
1515
post_patch_activity,
16-
schedule_to_close_timeout=timedelta(minutes=5),
16+
start_to_close_timeout=timedelta(seconds=5),
1717
)
1818
else:
1919
self._result = await workflow.execute_activity(
2020
pre_patch_activity,
21-
schedule_to_close_timeout=timedelta(minutes=5),
21+
start_to_close_timeout=timedelta(seconds=5),
2222
)
2323

2424
@workflow.query

patching/workflow_3_patch_deprecated.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@ async def run(self) -> None:
1313
workflow.deprecate_patch("my-patch")
1414
self._result = await workflow.execute_activity(
1515
post_patch_activity,
16-
schedule_to_close_timeout=timedelta(minutes=5),
16+
start_to_close_timeout=timedelta(seconds=5),
1717
)
1818

1919
@workflow.query

patching/workflow_4_patch_complete.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@ class MyWorkflow:
1212
async def run(self) -> None:
1313
self._result = await workflow.execute_activity(
1414
post_patch_activity,
15-
schedule_to_close_timeout=timedelta(minutes=5),
15+
start_to_close_timeout=timedelta(seconds=5),
1616
)
1717

1818
@workflow.query

0 commit comments

Comments
 (0)