Pick up core crate renames

Author: yuandrew

temporalio/bridge/sdk-core

@@ -140,7 +140,7 @@ def formatted(self) -> str:
         """Return a formatted form of this filter."""
         # We intentionally aren't using __str__ or __format__ so they can keep
         # their original dataclass impls
-        return f"{self.other_level},temporal_sdk_core={self.core_level},temporal_client={self.core_level},temporal_sdk={self.core_level}"
+        return f"{self.other_level},temporalio_sdk_core={self.core_level},temporalio_client={self.core_level},temporalio_sdk={self.core_level}"
 
 
 @dataclass(frozen=True)

temporalio/runtime.py

@@ -82,7 +82,7 @@ def configure_client(self, config: ClientConfig) -> ClientConfig:
         return config
 
     def configure_worker(self, config: WorkerConfig) -> WorkerConfig:
-        config["task_queue"] = "combined"
+        config["task_queue"] = "combined" + str(uuid.uuid4())
         return config
 
     async def connect_service_client(
@@ -114,7 +114,7 @@ def run_replayer(
 
 class MyWorkerPlugin(temporalio.worker.Plugin):
     def configure_worker(self, config: WorkerConfig) -> WorkerConfig:
-        config["task_queue"] = "replaced_queue"
+        config["task_queue"] = "replaced_queue" + str(uuid.uuid4())
         runner = config.get("workflow_runner")
         if isinstance(runner, SandboxedWorkflowRunner):
             config["workflow_runner"] = dataclasses.replace(
@@ -146,11 +146,11 @@ def run_replayer(
 async def test_worker_plugin_basic_config(client: Client) -> None:
     worker = Worker(
         client,
-        task_queue="queue",
+        task_queue="queue" + str(uuid.uuid4()),
         activities=[never_run_activity],
         plugins=[MyWorkerPlugin()],
     )
-    assert worker.config().get("task_queue") == "replaced_queue"
+    assert worker.config().get("task_queue").startswith("replaced_queue")
     assert [p.name() for p in worker.config().get("plugins", [])] == [
         MyWorkerPlugin().name()
     ]
@@ -159,20 +159,20 @@ async def test_worker_plugin_basic_config(client: Client) -> None:
     new_config = client.config()
     new_config["plugins"] = [MyCombinedPlugin()]
     client = Client(**new_config)
-    worker = Worker(client, task_queue="queue", activities=[never_run_activity])
-    assert worker.config().get("task_queue") == "combined"
+    worker = Worker(client, task_queue="queue" + str(uuid.uuid4()), activities=[never_run_activity])
+    assert worker.config().get("task_queue").startswith("combined")
     assert [p.name() for p in worker.config().get("plugins", [])] == [
         MyCombinedPlugin().name()
     ]
 
     # Test both. Client propagated plugins are called first, so the worker plugin overrides in this case
     worker = Worker(
         client,
-        task_queue="queue",
+        task_queue="queue" + str(uuid.uuid4()),
         activities=[never_run_activity],
         plugins=[MyWorkerPlugin()],
     )
-    assert worker.config().get("task_queue") == "replaced_queue"
+    assert worker.config().get("task_queue").startswith("replaced_queue")
     assert [p.name() for p in worker.config().get("plugins", [])] == [
         MyCombinedPlugin().name(),
         MyWorkerPlugin().name(),
@@ -201,7 +201,7 @@ def new_worker_wrapper(runtime_ref, client_ref, config):
     plugin2 = SimplePlugin("test-worker-plugin2")
     worker = Worker(
         client,
-        task_queue="queue",
+        task_queue="queue" + str(uuid.uuid4()),
         activities=[never_run_activity],
         plugins=[plugin1, plugin2],
     )
@@ -217,7 +217,7 @@ async def test_worker_duplicated_plugin(client: Client) -> None:
     with warnings.catch_warnings(record=True) as warning_list:
         worker = Worker(
             client,
-            task_queue="queue",
+            task_queue="queue" + str(uuid.uuid4()),
             activities=[never_run_activity],
             plugins=[MyCombinedPlugin()],
         )
@@ -230,7 +230,7 @@ async def test_worker_sandbox_restrictions(client: Client) -> None:
     with warnings.catch_warnings(record=True) as warning_list:
         worker = Worker(
             client,
-            task_queue="queue",
+            task_queue="queue" + str(uuid.uuid4()),
             activities=[never_run_activity],
             plugins=[MyWorkerPlugin()],
         )
@@ -332,7 +332,7 @@ async def test_simple_plugins(client: Client) -> None:
     # Test without plugin registered in client
     worker = Worker(
         client,
-        task_queue="queue",
+        task_queue="queue" + str(uuid.uuid4()),
         activities=[never_run_activity],
         workflows=[HelloWorkflow],
         plugins=[plugin],
@@ -343,7 +343,7 @@ async def test_simple_plugins(client: Client) -> None:
     # Test with plugin registered in client
     worker = Worker(
         new_client,
-        task_queue="queue",
+        task_queue="queue" + str(uuid.uuid4()),
         activities=[never_run_activity],
     )
     assert worker.config().get("workflows") == [HelloWorkflow2]
@@ -380,7 +380,7 @@ def converter(old: Optional[DataConverter]):
     )
     worker = Worker(
         client,
-        task_queue="queue",
+        task_queue="queue" + str(uuid.uuid4()) + str(uuid.uuid4()),
         workflows=[HelloWorkflow],
         activities=[never_run_activity],
         plugins=[plugin],
@@ -394,13 +394,13 @@ def __init__(self):
 
     def configure_worker(self, config: WorkerConfig) -> WorkerConfig:
         config = super().configure_worker(config)
-        config["task_queue"] = "override"
+        config["task_queue"] = "override" + str(uuid.uuid4())
         return config
 
 
 async def test_medium_plugin(client: Client) -> None:
     plugin = MediumPlugin()
     worker = Worker(
-        client, task_queue="queue", plugins=[plugin], workflows=[HelloWorkflow]
+        client, task_queue="queue" + str(uuid.uuid4()), plugins=[plugin], workflows=[HelloWorkflow]
     )
-    assert worker.config().get("task_queue") == "override"
+    assert worker.config().get("task_queue").startswith("override")

tests/test_plugins.py

@@ -188,7 +188,7 @@ async def has_log() -> bool:
     # Check record
     record = next((l for l in log_queue_list if "Failing workflow task" in l.message))
     assert record.levelno == logging.WARNING
-    assert record.name == f"{logger.name}-sdk_core::temporal_sdk_core::worker::workflow"
+    assert record.name == f"{logger.name}-sdk_core::temporalio_sdk_core::worker::workflow"
     assert record.temporal_log.fields["run_id"] == handle.result_run_id  # type: ignore
 
 

tests/test_runtime.py

@@ -221,64 +221,6 @@ def my_signal(self, value: str) -> None:
         workflow.logger.info(f"Signal: {value}")
 
 
-async def test_worker_versioning(client: Client, env: WorkflowEnvironment):
-    if env.supports_time_skipping:
-        pytest.skip("Java test server does not support worker versioning")
-    if not await worker_versioning_enabled(client):
-        pytest.skip("This server does not have worker versioning enabled")
-
-    task_queue = f"worker-versioning-{uuid.uuid4()}"
-    await client.update_worker_build_id_compatibility(
-        task_queue, BuildIdOpAddNewDefault("1.0")
-    )
-
-    async with new_worker(
-        client,
-        WaitOnSignalWorkflow,
-        activities=[say_hello],
-        task_queue=task_queue,
-        build_id="1.0",
-        use_worker_versioning=True,
-    ):
-        wf1 = await client.start_workflow(
-            WaitOnSignalWorkflow.run,
-            id=f"worker-versioning-1-{uuid.uuid4()}",
-            task_queue=task_queue,
-        )
-        # Sleep for a beat, otherwise it's possible for new workflow to start on 2.0
-        await asyncio.sleep(0.1)
-        await client.update_worker_build_id_compatibility(
-            task_queue, BuildIdOpAddNewDefault("2.0")
-        )
-        wf2 = await client.start_workflow(
-            WaitOnSignalWorkflow.run,
-            id=f"worker-versioning-2-{uuid.uuid4()}",
-            task_queue=task_queue,
-        )
-        async with new_worker(
-            client,
-            WaitOnSignalWorkflow,
-            activities=[say_hello],
-            task_queue=task_queue,
-            build_id="2.0",
-            use_worker_versioning=True,
-        ):
-            # Confirm reachability type parameter is respected. If it wasn't, list would have
-            # `OPEN_WORKFLOWS` in it.
-            reachability = await client.get_worker_task_reachability(
-                build_ids=["2.0"],
-                reachability_type=TaskReachabilityType.CLOSED_WORKFLOWS,
-            )
-            assert reachability.build_id_reachability["2.0"].task_queue_reachability[
-                task_queue
-            ] == [TaskReachabilityType.NEW_WORKFLOWS]
-
-            await wf1.signal(WaitOnSignalWorkflow.my_signal, "finish")
-            await wf2.signal(WaitOnSignalWorkflow.my_signal, "finish")
-            await wf1.result()
-            await wf2.result()
-
-
 async def test_worker_validate_fail(client: Client, env: WorkflowEnvironment):
     if env.supports_time_skipping:
         pytest.skip("Java test server does not appear to fail on invalid namespace")