Skip to content

Commit 499d7c4

Browse files
committed
Add comments
1 parent 97b2265 commit 499d7c4

File tree

2 files changed

+19
-6
lines changed

2 files changed

+19
-6
lines changed

tests/worker/test_replayer.py

+11-5
Original file line numberDiff line numberDiff line change
@@ -398,7 +398,7 @@ async def test_replayer_command_reordering_backward_compatibility() -> None:
398398
)
399399

400400

401-
workflow_res = None
401+
test_replayer_workflow_res = None
402402

403403

404404
class WorkerWorkflowResultInterceptor(Interceptor):
@@ -410,9 +410,9 @@ def workflow_interceptor_class(
410410

411411
class WorkflowResultInterceptor(WorkflowInboundInterceptor):
412412
async def execute_workflow(self, input: ExecuteWorkflowInput) -> Any:
413-
global workflow_res
413+
global test_replayer_workflow_res
414414
res = await super().execute_workflow(input)
415-
workflow_res = res
415+
test_replayer_workflow_res = res
416416
return res
417417

418418

@@ -471,7 +471,7 @@ async def test_replayer_async_ordering() -> None:
471471
workflows=[SignalsActivitiesTimersUpdatesTracingWorkflow],
472472
interceptors=[WorkerWorkflowResultInterceptor()],
473473
).replay_workflow(WorkflowHistory.from_json("fake", history))
474-
assert workflow_res == expected
474+
assert test_replayer_workflow_res == expected
475475

476476

477477
async def test_replayer_alternate_async_ordering() -> None:
@@ -483,4 +483,10 @@ async def test_replayer_alternate_async_ordering() -> None:
483483
workflows=[ActivityAndSignalsWhileWorkflowDown],
484484
interceptors=[WorkerWorkflowResultInterceptor()],
485485
).replay_workflow(WorkflowHistory.from_json("fake", history))
486-
assert workflow_res == ["act-start", "sig-1", "sig-2", "counter-2", "act-done"]
486+
assert test_replayer_workflow_res == [
487+
"act-start",
488+
"sig-1",
489+
"sig-2",
490+
"counter-2",
491+
"act-done",
492+
]

tests/worker/test_workflow.py

+8-1
Original file line numberDiff line numberDiff line change
@@ -6452,6 +6452,12 @@ async def test_concurrent_sleeps_use_proper_options(
64526452

64536453
@workflow.defn
64546454
class SignalsActivitiesTimersUpdatesTracingWorkflow:
6455+
"""
6456+
These handlers all do different things that will cause the event loop to yield, sometimes
6457+
until the next workflow task (ex: timer) sometimes within the workflow task (ex: future resolve
6458+
or wait condition).
6459+
"""
6460+
64556461
def __init__(self) -> None:
64566462
self.events: List[str] = []
64576463

@@ -6542,7 +6548,6 @@ async def run(self, activity_tq: str) -> List[str]:
65426548
await workflow.wait_condition(lambda: self.counter >= 2)
65436549
self.events.append(f"counter-{self.counter}")
65446550
await act_task
6545-
workflow.logger.warning(f"run done: {self.events}")
65466551
return self.events
65476552

65486553
@workflow.signal
@@ -6580,13 +6585,15 @@ async def test_alternate_async_loop_ordering(client: Client):
65806585
activities=[say_hello],
65816586
task_queue=task_queue,
65826587
):
6588+
# This sleep exists to make sure the first WFT is processed
65836589
await asyncio.sleep(0.2)
65846590

65856591
async with new_worker(
65866592
client,
65876593
activities=[say_hello],
65886594
task_queue=activity_tq,
65896595
):
6596+
# Make sure the activity starts being processed before sending signals
65906597
await asyncio.sleep(1)
65916598
await handle.signal(ActivityAndSignalsWhileWorkflowDown.dosig, "1")
65926599
await handle.signal(ActivityAndSignalsWhileWorkflowDown.dosig, "2")

0 commit comments

Comments
 (0)