Add some logs to help debug test flaking with timeouts

Author: VegetarianOrc

tests/contrib/test_opentelemetry.py

@@ -588,21 +588,28 @@ async def test_opentelemetry_safe_detach(client: Client):
 
         with LogCapturer().logs_captured(opentelemetry.context.logger) as capturer:
             try:
+                print("===== in detach test")
                 handle = await client.start_workflow(
                     CacheEvictionTearDownWorkflow.run,
                     id=f"wf-{uuid.uuid4()}",
                     task_queue=worker.task_queue,
                 )
 
                 # CacheEvictionTearDownWorkflow requires 3 signals to be sent
+                print("===== signal 1")
                 await handle.signal(CacheEvictionTearDownWorkflow.signal)
+                print("===== signal 2")
                 await handle.signal(CacheEvictionTearDownWorkflow.signal)
+                print("===== signal 3")
                 await handle.signal(CacheEvictionTearDownWorkflow.signal)
 
+                print("===== awaiting result")
                 await handle.result()
             finally:
                 sys.unraisablehook = old_hook
 
+            print("===== inspecting logs")
+
             # Confirm at least 1 exception
             if len(hook_calls) < 1:
                 logging.warning(
@@ -615,6 +622,6 @@ def otel_context_error(record: logging.LogRecord) -> bool:
                     and "Failed to detach context" in record.message
                 )
 
-            assert (
-                capturer.find(otel_context_error) is None
-            ), "Detach from context message should not be logged"
+            assert capturer.find(otel_context_error) is None, (
+                "Detach from context message should not be logged"
+            )

tests/helpers/cache_eviction.py

@@ -46,17 +46,23 @@ async def run(self) -> None:
         # Let's also start something in the background that we never wait on
         asyncio.create_task(asyncio.sleep(1000))
         try:
+            print("----- in evict workflow")
             # Wait for signal count to reach 2
             await asyncio.sleep(0.01)
+            print("----- waiting for signal")
             await workflow.wait_condition(lambda: self._signal_count > 1)
         finally:
             # This finally, on eviction, is actually called but the command
             # should be ignored
+            print("----- sleeping")
             await asyncio.sleep(0.01)
+            print("----- waiting for signals 2 & 3")
             await workflow.wait_condition(lambda: self._signal_count > 2)
             # Cancel gather tasks and wait on them, but ignore the errors
             for task in tasks:
                 task.cancel()
+
+            print("----- evict workflow ending")
             await gather_fut
 
     @workflow.signal