Revert "TEMP: Alter manual activity tests to not require worker"

This reverts commit 7127c0fe5296d6df4c174f2792447c98934a95ce.

Author: dandavison

tests/test_activity.py

@@ -11,10 +11,6 @@
 from temporalio.exceptions import ApplicationError, CancelledError
 from temporalio.worker import Worker
 
-STANDALONE_ACTIVITY_MATCHING_TASKS_IMPLEMENTED = False
-
-pytest.skip("Standalone activity is not implemented in server", allow_module_level=True)
-
 
 @activity.defn
 async def increment(input: int) -> int:
@@ -106,13 +102,12 @@ async def test_manual_completion(client: Client):
         activities=[async_activity],
         workflows=[WaitForSignalWorkflow],
     ):
-        if STANDALONE_ACTIVITY_MATCHING_TASKS_IMPLEMENTED:
-            # Wait for activity to start
-            await client.execute_workflow(
-                WaitForSignalWorkflow.run,
-                id=wait_for_signal_workflow_id,
-                task_queue=task_queue,
-            )
+        # Wait for activity to start
+        await client.execute_workflow(
+            WaitForSignalWorkflow.run,
+            id=wait_for_signal_workflow_id,
+            task_queue=task_queue,
+        )
         # Complete activity manually
         async_activity_handle = client.get_async_activity_handle(
             activity_id=activity_id,
@@ -143,14 +138,11 @@ async def test_manual_cancellation(client: Client):
         activities=[async_activity],
         workflows=[WaitForSignalWorkflow],
     ):
-        if STANDALONE_ACTIVITY_MATCHING_TASKS_IMPLEMENTED:
-            # Wait for activity to start
-            await client.execute_workflow(
-                WaitForSignalWorkflow.run,
-                id=wait_for_signal_workflow_id,
-                task_queue=task_queue,
-            )
-        # Cancel activity manually
+        await client.execute_workflow(
+            WaitForSignalWorkflow.run,
+            id=wait_for_signal_workflow_id,
+            task_queue=task_queue,
+        )
         async_activity_handle = client.get_async_activity_handle(
             activity_id=activity_id,
             run_id=activity_handle.run_id,
@@ -182,14 +174,11 @@ async def test_manual_fail(client: Client):
         activities=[async_activity],
         workflows=[WaitForSignalWorkflow],
     ):
-        if STANDALONE_ACTIVITY_MATCHING_TASKS_IMPLEMENTED:
-            # Wait for activity to start
-            await client.execute_workflow(
-                WaitForSignalWorkflow.run,
-                id=wait_for_signal_workflow_id,
-                task_queue=task_queue,
-            )
-        # Fail activity manually
+        await client.execute_workflow(
+            WaitForSignalWorkflow.run,
+            id=wait_for_signal_workflow_id,
+            task_queue=task_queue,
+        )
         async_activity_handle = client.get_async_activity_handle(
             activity_id=activity_id,
             run_id=activity_handle.run_id,
@@ -241,13 +230,13 @@ async def test_manual_heartbeat(client: Client):
         activities=[activity_for_testing_heartbeat],
         workflows=[WaitForSignalWorkflow],
     ):
-        # Send heartbeat manually
         async_activity_handle = client.get_async_activity_handle(
             activity_id=activity_id,
             run_id=activity_handle.run_id,
         )
         await async_activity_handle.heartbeat("Test heartbeat details")
-        await client.get_workflow_handle(
+        await client.get_workflow_handle_for(
+            WaitForSignalWorkflow.run,
             workflow_id=wait_for_signal_workflow_id,
         ).signal(WaitForSignalWorkflow.signal)
         assert await activity_handle.result() == "Test heartbeat details"