From 1f08a529fca3fcb56e1ce4e4f03d78ef760b6ac0 Mon Sep 17 00:00:00 2001 From: DABH Date: Thu, 10 Sep 2026 00:37:19 -0500 Subject: [PATCH] Give manual activity tests time for the start handshake test_manual_heartbeat and its siblings start a standalone activity with a 5s start-to-close timeout, then wait for the activity to report that it started through an EventWorkflow before completing, cancelling, failing or heartbeating it by ID. That handshake includes the first workflow task of a cold worker, which on a loaded macOS runner took over 5s; the attempt timed out and the heartbeat failed with RPCError NOT_FOUND ("activity not found for ID"). Nothing in these tests depends on the attempt timing out, so give the attempt a minute. --- tests/test_activity.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/tests/test_activity.py b/tests/test_activity.py index a5682f221..53ffe835e 100644 --- a/tests/test_activity.py +++ b/tests/test_activity.py @@ -752,7 +752,7 @@ async def test_manual_completion(client: Client, env: WorkflowEnvironment): ActivityInput(event_workflow_id=event_workflow_id), id=activity_id, task_queue=task_queue, - start_to_close_timeout=timedelta(seconds=5), + start_to_close_timeout=timedelta(minutes=1), ) async with Worker( @@ -794,7 +794,7 @@ async def test_manual_cancellation(client: Client, env: WorkflowEnvironment): ActivityInput(event_workflow_id=event_workflow_id), id=activity_id, task_queue=task_queue, - start_to_close_timeout=timedelta(seconds=5), + start_to_close_timeout=timedelta(minutes=1), ) async with Worker( @@ -855,7 +855,7 @@ async def test_manual_failure(client: Client, env: WorkflowEnvironment): ActivityInput(event_workflow_id=event_workflow_id), id=activity_id, task_queue=task_queue, - start_to_close_timeout=timedelta(seconds=5), + start_to_close_timeout=timedelta(minutes=1), ) async with Worker( client, @@ -932,7 +932,7 @@ async def test_manual_heartbeat(client: Client, env: WorkflowEnvironment): ), id=activity_id, task_queue=task_queue, - start_to_close_timeout=timedelta(seconds=5), + start_to_close_timeout=timedelta(minutes=1), ) wait_for_activity_start_wf_handle = await client.start_workflow( EventWorkflow.wait,