Use new CLI RC to avoid persistence bug

Author: Sushisource

tests/conftest.py

@@ -115,7 +115,7 @@ async def env(env_type: str) -> AsyncGenerator[WorkflowEnvironment, None]:
                 "system.enableDeploymentVersions=true",
             ],
             # TODO: Remove after next CLI release
-            dev_server_download_version="v1.3.1-priority.0",
+            dev_server_download_version="v1.3.1-persistence-fix.0",
         )
     elif env_type == "time-skipping":
         env = await WorkflowEnvironment.start_time_skipping()

tests/worker/test_worker.py

@@ -274,6 +274,17 @@ async def test_can_run_resource_based_worker(client: Client, env: WorkflowEnviro
         # Ensure we can assume defaults when specifying only some options
         activity_config=ResourceBasedSlotConfig(minimum_slots=1),
     )
+    prom_addr = f"127.0.0.1:{find_free_port()}"
+    runtime = Runtime(
+        telemetry=TelemetryConfig(
+            metrics=PrometheusConfig(bind_address=prom_addr),
+        )
+    )
+    client = await Client.connect(
+        client.service_client.config.target_host,
+        namespace=client.namespace,
+        runtime=runtime,
+    )
     async with new_worker(
         client,
         WaitOnSignalWorkflow,
@@ -285,9 +296,16 @@ async def test_can_run_resource_based_worker(client: Client, env: WorkflowEnviro
             id=f"resource-based-{uuid.uuid4()}",
             task_queue=w.task_queue,
         )
+        # Resource metrics get emitted on a 1 second tick
+        await asyncio.sleep(1)
         await wf1.signal(WaitOnSignalWorkflow.my_signal, "finish")
         await wf1.result()
 
+    with urlopen(url=f"http://{prom_addr}/metrics") as f:
+        prom_str: str = f.read().decode("utf-8")
+    # verify resource metrics are being emitted
+    assert "resource_slots_mem_usage" in prom_str
+
 
 async def test_can_run_composite_tuner_worker(client: Client, env: WorkflowEnvironment):
     resource_based_options = ResourceBasedTunerConfig(0.5, 0.5)