Cleanup, remove bad test

Author: tconley1428

temporalio/activity.py

@@ -162,7 +162,6 @@ class ActivityCancellationDetails:
     def _from_proto(
         proto: temporalio.bridge.proto.activity_task.ActivityCancellationDetails,
     ) -> ActivityCancellationDetails:
-        print(f"Building activity cancellation details, reset: {proto.is_reset}")
         return ActivityCancellationDetails(
             not_found=proto.is_not_found,
             cancel_requested=proto.is_cancelled,

temporalio/service.py

@@ -34,7 +34,7 @@
 logger = logging.getLogger(__name__)
 
 # Set to true to log all requests and responses
-LOG_PROTOS = True
+LOG_PROTOS = False
 
 
 @dataclass

temporalio/worker/_activity.py

@@ -152,8 +152,6 @@ async def raise_from_exception_queue() -> NoReturn:
                     await exception_task
                 task = await poll_task
 
-                logger.info(f"Activity task {task}")
-
                 if task.HasField("start"):
                     # Cancelled event and sync field will be updated inside
                     # _run_activity when the activity function is obtained. Max

tests/worker/test_activity.py

@@ -1489,36 +1489,6 @@ async def h():
     assert result.result == "details: Some detail"
 
 
-async def test_activity_reset(client: Client, worker: ExternalWorker):
-    @activity.defn
-    async def reset_activity() -> None:
-        req = temporalio.api.workflowservice.v1.ResetActivityRequest(
-            namespace=client.namespace,
-            execution=temporalio.api.common.v1.WorkflowExecution(
-                workflow_id=activity.info().workflow_id,
-                run_id=activity.info().workflow_run_id,
-            ),
-            id=activity.info().activity_id,
-        )
-        activity.logger.info(f"Sending reset request: {req}")
-        await client.workflow_service.reset_activity(req)
-        reset = False
-        for _ in range(5):
-            activity.heartbeat()
-            try:
-                if reset:
-                    return None
-                await asyncio.sleep(0.3)
-            except Exception as e:
-                activity.logger.warning("Exception: ", e)
-                reset = True
-                raise
-
-        assert False
-
-    await _execute_workflow_with_activity(client, worker, reset_activity)
-
-
 async def test_activity_reset_catch(client: Client, worker: ExternalWorker):
     @activity.defn
     async def wait_cancel() -> str: