WIP

Author: dandavison

tests/worker/test_nexus.py

@@ -211,8 +211,12 @@ async def run(
             print(f"🌈 {'cancel returned':<24}: {cancel_ret}")
 
         print(f"🌈 {'before await op_handle':<24}: {op_handle}")
-        output = await op_handle
-        print(f"🌈 {'after await op_handle':<24}: {op_handle}")
+        try:
+            output = await op_handle
+        except Exception as e:
+            print(f"🌈 {'await op_handle failed':<24}: {e.__class__}({e})")
+            raise
+        print(f"🌈 {'after await op_handle':<24}: {op_handle} -> {output}")
         return output
 
     @workflow.update
@@ -274,6 +278,9 @@ async def test_async_response(
     request_cancel: bool,
     use_shorthand_defined_operation: bool,
 ):
+    print(
+        f"🌈 {'test_async_response':<24}: {request_cancel=} {use_shorthand_defined_operation=}"
+    )
     task_queue = str(uuid.uuid4())
     async with Worker(
         client,
@@ -283,7 +290,7 @@ async def test_async_response(
         workflow_runner=UnsandboxedWorkflowRunner(),
     ):
         await create_nexus_endpoint(task_queue, client)
-        operation_workflow_id = str(uuid.uuid4())
+        operation_workflow_id = "default-workflow-id"
 
         # Start the caller workflow.
         block_forever_waiting_for_cancellation = request_cancel