@@ -3,7 +3,7 @@
 See https://github.com/temporalio/sdk-python/tree/main#nexus
 """
 
-from ._decorators import workflow_run_operation, temporal_operation
+from ._decorators import temporal_operation, workflow_run_operation
 from ._operation_context import (
     Info,
     LoggerAdapter,
@@ -18,8 +18,8 @@
     wait_for_worker_shutdown,
     wait_for_worker_shutdown_sync,
 )
-from ._token import WorkflowHandle
 from ._temporal_client import TemporalNexusClient, TemporalOperationResult
+from ._token import WorkflowHandle
 
 __all__ = (
     "workflow_run_operation",
 
@@ -1,7 +1,7 @@
 from __future__ import annotations
 
 import asyncio
-from collections.abc import Awaitable, Callable, Sequence, Mapping
+from collections.abc import Awaitable, Callable, Mapping, Sequence
 from dataclasses import dataclass
 from datetime import timedelta
 from typing import (
@@ -11,14 +11,18 @@
     Generic,
     Self,
     TypeVar,
-    overload,
     cast,
+    overload,
 )
 
 from nexusrpc import HandlerError, HandlerErrorType
 from nexusrpc.handler import StartOperationResultAsync, StartOperationResultSync
 
 import temporalio.common
+from temporalio.nexus._operation_context import (
+    _start_nexus_backing_workflow,
+    _TemporalStartOperationContext,
+)
 from temporalio.types import (
     MethodAsyncNoParam,
     MethodAsyncSingleParam,
@@ -27,10 +31,6 @@
     ReturnType,
     SelfType,
 )
-from temporalio.nexus._operation_context import (
-    _TemporalStartOperationContext,
-    _start_nexus_backing_workflow,
-)
 
 if TYPE_CHECKING:
     import temporalio.client
 
@@ -1,9 +1,9 @@
 from __future__ import annotations
 
 import base64
-from enum import IntEnum
 import json
 from dataclasses import dataclass
+from enum import IntEnum
 from typing import TYPE_CHECKING, Any, Generic, Self
 
 from nexusrpc import OutputT
 
@@ -235,13 +235,13 @@ async def test_invoke_by_operation_definition_happy_path(self) -> None:
         _output_2_1: MyOutput = await _handle_2
 
         # temporal operation
-        _output_3: None = await nexus_client.execute_operation(
+        _output_3: None = await nexus_client.execute_operation(  # type: ignore
             MyService.my_temporal_operation, 0
         )
         _handle_3: workflow.NexusOperationHandle[
             None
         ] = await nexus_client.start_operation(MyService.my_temporal_operation, 0)
-        _output_3_1: None = await _handle_3
+        _output_3_1: None = await _handle_3  # type: ignore
 
 
 @workflow.defn
@@ -281,15 +281,15 @@ async def test_invoke_by_operation_handler_happy_path(self) -> None:
         _output_2_1: MyOutput = await _handle_2
 
         # temporal operation
-        _output_3: None = await nexus_client.execute_operation(
+        _output_3: None = await nexus_client.execute_operation(  # type: ignore
             MyServiceHandler.my_temporal_operation, 0
         )
         _handle_3: workflow.NexusOperationHandle[
             None
         ] = await nexus_client.start_operation(
             MyServiceHandler.my_temporal_operation, 0
         )
-        _output_3_1: None = await _handle_3
+        _output_3_1: None = await _handle_3  # type: ignore
 
 
 @workflow.defn
 
@@ -1,8 +1,5 @@
-import asyncio
 import uuid
 from dataclasses import dataclass
-from datetime import datetime, timezone
-from typing import Any
 
 import nexusrpc
 import pytest
@@ -12,7 +9,6 @@
     service_handler,
 )
 
-
 import temporalio.exceptions
 from temporalio import nexus, workflow
 from temporalio.client import Client, WorkflowFailureError
 
@@ -23,8 +23,8 @@
 from temporalio.common import WorkflowIDConflictPolicy
 from temporalio.testing import WorkflowEnvironment
 from temporalio.worker import Worker
-from tests.helpers.nexus import make_nexus_endpoint_name
 from tests.helpers import assert_event_subsequence
+from tests.helpers.nexus import make_nexus_endpoint_name
 from tests.nexus.test_workflow_caller_cancellation_types import (
     get_event_time,
     has_event,