windows compatibility

Author: chrishayuk

src/chuk_tool_processor/execution/strategies/inprocess_strategy.py

@@ -20,6 +20,7 @@
 import asyncio
 import inspect
 import os
+import platform
 from contextlib import asynccontextmanager
 from datetime import datetime, timezone
 from typing import Any, List, Optional, AsyncIterator, Set, Tuple
@@ -214,7 +215,7 @@ async def _stream_tool_call(
                 error="System is shutting down",
                 start_time=now,
                 end_time=now,
-                machine=os.uname().nodename,
+                machine=platform.node(),
                 pid=os.getpid(),
             )
             await queue.put(result)
@@ -232,7 +233,7 @@ async def _stream_tool_call(
                     error=f"Tool '{call.tool}' not found in any namespace",
                     start_time=now,
                     end_time=now,
-                    machine=os.uname().nodename,
+                    machine=platform.node(),
                     pid=os.getpid(),
                 )
                 await queue.put(result)
@@ -265,7 +266,7 @@ async def _stream_tool_call(
                 error="Execution was cancelled",
                 start_time=now,
                 end_time=now,
-                machine=os.uname().nodename,
+                machine=platform.node(),
                 pid=os.getpid(),
             )
             await queue.put(result)
@@ -279,7 +280,7 @@ async def _stream_tool_call(
                 error=f"Error setting up execution: {e}",
                 start_time=now,
                 end_time=now,
-                machine=os.uname().nodename,
+                machine=platform.node(),
                 pid=os.getpid(),
             )
             await queue.put(result)
@@ -304,7 +305,7 @@ async def _stream_with_timeout(
             timeout: Timeout in seconds (required)
         """
         start_time = datetime.now(timezone.utc)
-        machine = os.uname().nodename
+        machine = platform.node()
         pid = os.getpid()
 
         logger.debug("Streaming %s with %ss timeout", call.tool, timeout)
@@ -412,7 +413,7 @@ async def _execute_single_call(
             Tool execution result
         """
         pid = os.getpid()
-        machine = os.uname().nodename
+        machine = platform.node()
         start = datetime.now(timezone.utc)
 
         logger.debug("Executing %s with %ss timeout", call.tool, timeout)

src/chuk_tool_processor/execution/strategies/subprocess_strategy.py

@@ -20,6 +20,7 @@
 import functools
 import inspect
 import os
+import platform
 import pickle
 import signal
 import sys
@@ -82,7 +83,7 @@ def _serialized_tool_worker(
 
     start_time = datetime.now(timezone.utc)
     pid = os.getpid()
-    hostname = os.uname().nodename
+    hostname = platform.node()
 
     result_data = {
         "tool": tool_name,
@@ -290,7 +291,7 @@ async def run(
                     error="System is shutting down",
                     start_time=datetime.now(timezone.utc),
                     end_time=datetime.now(timezone.utc),
-                    machine=os.uname().nodename,
+                    machine=platform.node(),
                     pid=os.getpid(),
                 )
                 for call in calls
@@ -341,7 +342,7 @@ async def stream_run(
                     error="System is shutting down",
                     start_time=datetime.now(timezone.utc),
                     end_time=datetime.now(timezone.utc),
-                    machine=os.uname().nodename,
+                    machine=platform.node(),
                     pid=os.getpid(),
                 )
             return
@@ -422,7 +423,7 @@ async def _execute_single_call(
                     error=f"Tool '{call.tool}' not found in any namespace",
                     start_time=start_time,
                     end_time=datetime.now(timezone.utc),
-                    machine=os.uname().nodename,
+                    machine=platform.node(),
                     pid=os.getpid(),
                 )
 
@@ -456,7 +457,7 @@ async def _execute_single_call(
                     error=f"Tool serialization failed: {str(e)}",
                     start_time=start_time,
                     end_time=datetime.now(timezone.utc),
-                    machine=os.uname().nodename,
+                    machine=platform.node(),
                     pid=os.getpid(),
                 )
 
@@ -504,7 +505,7 @@ async def _execute_single_call(
                     error=result_data.get("error"),
                     start_time=result_data.get("start_time", start_time),
                     end_time=result_data.get("end_time", end_time),
-                    machine=result_data.get("machine", os.uname().nodename),
+                    machine=result_data.get("machine", platform.node()),
                     pid=result_data.get("pid", os.getpid()),
                 )
 
@@ -520,7 +521,7 @@ async def _execute_single_call(
                     error=f"Worker process timed out after {safety_timeout}s",
                     start_time=start_time,
                     end_time=end_time,
-                    machine=os.uname().nodename,
+                    machine=platform.node(),
                     pid=os.getpid(),
                 )
 
@@ -536,7 +537,7 @@ async def _execute_single_call(
                     error="Worker process crashed",
                     start_time=start_time,
                     end_time=datetime.now(timezone.utc),
-                    machine=os.uname().nodename,
+                    machine=platform.node(),
                     pid=os.getpid(),
                 )
 
@@ -548,7 +549,7 @@ async def _execute_single_call(
                 error="Execution was cancelled",
                 start_time=start_time,
                 end_time=datetime.now(timezone.utc),
-                machine=os.uname().nodename,
+                machine=platform.node(),
                 pid=os.getpid(),
             )
 
@@ -565,7 +566,7 @@ async def _execute_single_call(
                 error=f"Error: {str(e)}",
                 start_time=start_time,
                 end_time=end_time,
-                machine=os.uname().nodename,
+                machine=platform.node(),
                 pid=os.getpid(),
             )
 

src/chuk_tool_processor/models/tool_result.py

@@ -5,6 +5,7 @@
 from __future__ import annotations
 
 import os
+import platform
 import uuid
 from datetime import datetime, timezone
 from typing import Any, Dict, Optional, List
@@ -63,7 +64,7 @@ class ToolResult(BaseModel):
         description="UTC timestamp when execution finished"
     )
     machine: str = Field(
-        default_factory=lambda: os.uname().nodename,
+        default_factory=lambda: platform.node(),
         description="Hostname where the tool ran"
     )
     pid: int = Field(