CI fix

Author: cretz

.github/workflows/ci.yml

@@ -43,7 +43,7 @@ jobs:
       - run: poetry install --no-root -E opentelemetry
       - run: poe lint
       - run: poe build-develop
-      - run: poe test -s -o log_cli_level=DEBUG
+      - run: poe test -x -s -o log_cli_level=DEBUG
       - run: poe test -s -o log_cli_level=DEBUG --workflow-environment time-skipping
 
       # Confirm protos are already generated properly

temporalio/testing/workflow.py

@@ -91,7 +91,6 @@ async def start_local(
         temporalite_existing_path: Optional[str] = None,
         temporalite_database_filename: Optional[str] = None,
         temporalite_log_format: str = "pretty",
-        # TODO(cretz): Document that you can set to None to translate from Python level
         temporalite_log_level: Optional[str] = "warn",
         temporalite_download_version: str = "default",
         temporalite_extra_args: Sequence[str] = [],

tests/testing/test_workflow.py

@@ -1,4 +1,5 @@
 import asyncio
+import logging
 import uuid
 from datetime import datetime, timedelta, timezone
 from time import monotonic
@@ -18,6 +19,8 @@
 from temporalio.testing import WorkflowEnvironment
 from tests.worker.test_workflow import new_worker
 
+logger = logging.getLogger(__name__)
+
 
 @workflow.defn
 class ReallySlowWorkflow:
@@ -36,29 +39,45 @@ async def some_signal(self) -> None:
 
 
 async def test_workflow_env_time_skipping_basic():
-    async with await WorkflowEnvironment.start_time_skipping() as env:
-        async with new_worker(env.client, ReallySlowWorkflow) as worker:
-            # Check that time is around now
-            assert_timestamp_from_now(await env.get_current_time(), 0)
-            # Run workflow
-            assert "all done" == await env.client.execute_workflow(
-                ReallySlowWorkflow.run,
-                id=f"workflow-{uuid.uuid4()}",
-                task_queue=worker.task_queue,
-            )
-            # Check that the time is around 100000 seconds after now
-            assert_timestamp_from_now(await env.get_current_time(), 100000)
+    print("CI LOGA1")
+    try:
+        async with await WorkflowEnvironment.start_time_skipping() as env:
+            print("CI LOGA2")
+            async with new_worker(env.client, ReallySlowWorkflow) as worker:
+                print("CI LOGA3")
+                # Check that time is around now
+                assert_timestamp_from_now(await env.get_current_time(), 0)
+                # Run workflow
+                print("CI LOGA4")
+                assert "all done" == await env.client.execute_workflow(
+                    ReallySlowWorkflow.run,
+                    id=f"workflow-{uuid.uuid4()}",
+                    task_queue=worker.task_queue,
+                )
+                print("CI LOGA5", datetime.now())
+                # Check that the time is around 100000 seconds after now
+                assert_timestamp_from_now(await env.get_current_time(), 100000)
+                print("CI LOGA6", datetime.now())
+            print("CI LOGA7", datetime.now())
+        print("CI LOGA8", datetime.now())
+    except:
+        logger.exception("OH NO")
+        raise
 
 
 async def test_workflow_env_time_skipping_manual():
+    print("CI LOGB1", datetime.now())
     async with await WorkflowEnvironment.start_time_skipping() as env:
+        print("CI LOGB2", datetime.now())
         async with new_worker(env.client, ReallySlowWorkflow) as worker:
+            print("CI LOGB3", datetime.now())
             # Start workflow
             handle = await env.client.start_workflow(
                 ReallySlowWorkflow.run,
                 id=f"workflow-{uuid.uuid4()}",
                 task_queue=worker.task_queue,
             )
+            print("CI LOGB4")
 
             async def workflow_current_time() -> float:
                 # We send signal first since query timestamp is based on last
@@ -67,11 +86,17 @@ async def workflow_current_time() -> float:
                 return await handle.query(ReallySlowWorkflow.current_time)
 
             # Confirm query will say we're near current time
+            print("CI LOGB5")
             assert_timestamp_from_now(await workflow_current_time(), 0)
 
             # Sleep and confirm query will say we're near that time
+            print("CI LOGB6")
             await env.sleep(1000)
+            print("CI LOGB7")
             assert_timestamp_from_now(await workflow_current_time(), 1000)
+            print("CI LOGB8")
+        print("CI LOGB9")
+    print("CI LOGB10")
 
 
 class Activities: