Rename transport

Author: dandavison

README.md

@@ -188,7 +188,7 @@ import asyncio
 import uuid
 
 from mcp import ClientSession
-from nexusmcp import WorkflowNexusTransport
+from nexusmcp import WorkflowTransport
 from pydantic import BaseModel
 from temporalio import workflow
 from temporalio.client import Client
@@ -204,7 +204,7 @@ class AgentWorkflowInput(BaseModel):
 class AgentWorkflow:
     @workflow.run
     async def run(self, input: AgentWorkflowInput):
-        transport = WorkflowNexusTransport(input.endpoint)
+        transport = WorkflowTransport(input.endpoint)
         async with transport.connect() as (read_stream, write_stream):
             async with ClientSession(read_stream, write_stream) as session:
                 await session.initialize()

nexusmcp/__init__.py

@@ -2,8 +2,8 @@
 
 with workflow.unsafe.imports_passed_through():
     from .inbound_gateway import InboundGateway
-    from .nexus_transport import WorkflowNexusTransport
     from .service import MCPService
     from .service_handler import MCPServiceHandler, exclude
+    from .workflow_transport import WorkflowTransport
 
-__all__ = ["MCPService", "MCPServiceHandler", "InboundGateway", "exclude", "WorkflowNexusTransport"]
+__all__ = ["MCPService", "MCPServiceHandler", "InboundGateway", "exclude", "WorkflowTransport"]

nexusmcp/nexus_transport.py nexusmcp/workflow_transport.pynexusmcp/nexus_transport.py renamed to nexusmcp/workflow_transport.py

@@ -11,20 +11,19 @@
 from .service import MCPService
 
 
-class WorkflowNexusTransport:
+class WorkflowTransport:
     """
-    Nexus MCP Transport for use in Temporal workflows.
+    An MCP Transport for use in Temporal workflows.
 
-    This class provides a transport that proxies MCP requests to a Temporal Nexus service. It can be
-    used to make MCP calls via `mcp.ClientSession` from Temporal workflow code.
+    This class provides a transport that proxies MCP requests from a Temporal Workflow to a Temporal
+    Nexus service. It can be used to make MCP calls via `mcp.ClientSession` from Temporal workflow
+    code.
 
     Example:
-        ```python
-        async with WorkflowNexusTransport("my-endpoint") as (read_stream, write_stream):
+        ```python async with WorkflowNexusTransport("my-endpoint") as (read_stream, write_stream):
             async with ClientSession(read_stream, write_stream) as session:
-                await session.initialize()
-                await session.list_tools()
-                await session.call_tool("my-service/my-operation", {"arg": "value"})
+                await session.initialize() await session.list_tools() await
+                session.call_tool("my-service/my-operation", {"arg": "value"})
         ```
     """
 

tests/test_workflow_caller.py

@@ -10,7 +10,7 @@
 from temporalio.testing import WorkflowEnvironment
 from temporalio.worker import Worker
 
-from nexusmcp.nexus_transport import WorkflowNexusTransport
+from nexusmcp import WorkflowTransport
 
 from .service import TestServiceHandler, mcp_service
 
@@ -25,7 +25,7 @@ class MCPCallerWorkflowInput:
 class MCPCallerWorkflow:
     @workflow.run
     async def run(self, input: MCPCallerWorkflowInput) -> None:
-        transport = WorkflowNexusTransport(input.endpoint)
+        transport = WorkflowTransport(input.endpoint)
         async with transport.connect() as (read_stream, write_stream):
             async with ClientSession(read_stream, write_stream) as session:
                 await session.initialize()