uv run ruff check --fix

Author: dandavison

scripts/gen_protos.py

@@ -6,7 +6,7 @@
 import tempfile
 from functools import partial
 from pathlib import Path
-from typing import List, Mapping, Optional
+from typing import List, Mapping
 
 base_dir = Path(__file__).parent.parent
 proto_dir = (
@@ -25,8 +25,8 @@
     v
     for v in proto_dir.glob("**/*.proto")
     if not str(v).startswith(str(testsrv_proto_dir / "dependencies"))
-    and not "health" in str(v)
-    and not "google" in str(v)
+    and "health" not in str(v)
+    and "google" not in str(v)
 ]
 proto_paths.extend(test_proto_dir.glob("**/*.proto"))
 proto_paths.extend(additional_proto_dir.glob("**/*.proto"))
@@ -95,7 +95,7 @@ def fix_generated_output(base_path: Path):
         message_names = sorted(message_names)
         if message_names:
             f.write(
-                f'\n__all__ = [\n    "' + '",\n    "'.join(message_names) + '",\n]\n'
+                '\n__all__ = [\n    "' + '",\n    "'.join(message_names) + '",\n]\n'
             )
         # gRPC imports
         if "service_pb2_grpc" in imports:
@@ -115,7 +115,7 @@ def fix_generated_output(base_path: Path):
                 message_names.append(message)
             # __all__
             message_names = sorted(message_names)
-            f.write(f'    __all__.extend(["' + '", "'.join(message_names) + '"])\n')
+            f.write('    __all__.extend(["' + '", "'.join(message_names) + '"])\n')
             f.write("except ImportError:\n    pass")
 
 

temporalio/activity.py

@@ -244,7 +244,7 @@ def in_activity() -> bool:
     Returns:
         True if in an activity, False otherwise.
     """
-    return not _current_context.get(None) is None
+    return _current_context.get(None) is not None
 
 
 def info() -> Info:

temporalio/bridge/client.py

@@ -13,7 +13,6 @@
 
 import temporalio.bridge.runtime
 import temporalio.bridge.temporal_sdk_bridge
-from temporalio.bridge.temporal_sdk_bridge import RPCError
 
 
 @dataclass

temporalio/bridge/worker.py

@@ -35,7 +35,6 @@
 from temporalio.bridge.temporal_sdk_bridge import (
     CustomSlotSupplier as BridgeCustomSlotSupplier,
 )
-from temporalio.bridge.temporal_sdk_bridge import PollShutdownError
 
 
 @dataclass

temporalio/worker/_worker.py

@@ -29,7 +29,7 @@
 
 from ._activity import SharedStateManager, _ActivityWorker
 from ._interceptor import Interceptor
-from ._tuning import WorkerTuner, _to_bridge_slot_supplier
+from ._tuning import WorkerTuner
 from ._workflow import _WorkflowWorker
 from ._workflow_instance import UnsandboxedWorkflowRunner, WorkflowRunner
 from .workflow_sandbox import SandboxedWorkflowRunner

tests/conftest.py

@@ -1,6 +1,4 @@
 import asyncio
-import logging
-import multiprocessing
 import os
 import sys
 from typing import AsyncGenerator

tests/test_converter.py

@@ -36,7 +36,6 @@
 import temporalio.api.common.v1
 import temporalio.common
 from temporalio.api.common.v1 import Payload, Payloads
-from temporalio.api.common.v1 import Payload as AnotherNameForPayload
 from temporalio.api.failure.v1 import Failure
 from temporalio.common import RawValue
 from temporalio.converter import (

tests/worker/workflow_sandbox/test_importer.py

@@ -19,7 +19,7 @@
 def test_workflow_sandbox_importer_invalid_module():
     with pytest.raises(RestrictedWorkflowAccessError) as err:
         with Importer(restrictions, RestrictionContext()).applied():
-            import tests.worker.workflow_sandbox.testmodules.invalid_module
+            pass
     assert (
         err.value.qualified_name
         == "tests.worker.workflow_sandbox.testmodules.invalid_module"