updated agent workspace logic

Author: prassanna-ravishankar

.gitignore

@@ -16,4 +16,7 @@ Brewfile.lock.json
 
 .DS_Store
 
-examples/**/uv.lock
+examples/**/uv.lock
+
+# Claude workspace directories
+.claude-workspace/

examples/tutorials/10_async/10_temporal/090_claude_agents_sdk_mvp/project/run_worker.py

@@ -12,8 +12,8 @@
 import os
 import asyncio
 
-# Import workflow and workspace activity
-from project.workflow import ClaudeMvpWorkflow, create_workspace_directory
+# Import workflow
+from project.workflow import ClaudeMvpWorkflow
 
 from agentex.lib.utils.logging import make_logger
 from agentex.lib.environment_variables import EnvironmentVariables
@@ -24,6 +24,7 @@
 from agentex.lib.core.temporal.plugins.claude_agents import (
     ContextInterceptor,  # Reuse from OpenAI!
     run_claude_agent_activity,
+    create_workspace_directory,
 )
 
 logger = make_logger(__name__)

examples/tutorials/10_async/10_temporal/090_claude_agents_sdk_mvp/project/workflow.py

@@ -19,10 +19,9 @@
 from __future__ import annotations
 
 import os
-from pathlib import Path
 from datetime import timedelta
 
-from temporalio import activity, workflow
+from temporalio import workflow
 from temporalio.common import RetryPolicy
 from claude_agent_sdk.types import AgentDefinition
 
@@ -35,8 +34,11 @@
 from agentex.lib.core.temporal.types.workflow import SignalName
 from agentex.lib.core.temporal.workflows.workflow import BaseWorkflow
 
-# Import Claude activity
-from agentex.lib.core.temporal.plugins.claude_agents import run_claude_agent_activity
+# Import Claude activities
+from agentex.lib.core.temporal.plugins.claude_agents import (
+    run_claude_agent_activity,
+    create_workspace_directory,
+)
 
 environment_variables = EnvironmentVariables.refresh()
 
@@ -59,21 +61,6 @@ class StateModel(BaseModel):
     turn_number: int = 0
 
 
-# Activity for workspace creation (avoids determinism issues)
-@activity.defn
-async def create_workspace_directory(task_id: str, workspace_root: str | None = None) -> str:
-    """Create workspace directory for task - runs as Temporal activity"""
-    if workspace_root is None:
-        # Use project-relative workspace for local development
-        project_dir = Path(__file__).parent.parent
-        workspace_root = str(project_dir / "workspace")
-
-    workspace_path = os.path.join(workspace_root, task_id)
-    os.makedirs(workspace_path, exist_ok=True)
-    logger.info(f"Created workspace: {workspace_path}")
-    return workspace_path
-
-
 @workflow.defn(name=environment_variables.WORKFLOW_NAME)
 class ClaudeMvpWorkflow(BaseWorkflow):
     """Minimal Claude agent workflow - MVP v0

src/agentex/lib/core/temporal/plugins/claude_agents/activities.py

@@ -4,7 +4,6 @@
 
 import os
 from typing import Any
-from pathlib import Path
 
 from temporalio import activity
 from claude_agent_sdk import AgentDefinition, ClaudeSDKClient, ClaudeAgentOptions
@@ -27,15 +26,15 @@ async def create_workspace_directory(task_id: str, workspace_root: str | None =
 
     Args:
         task_id: Task ID for workspace directory name
-        workspace_root: Root directory for workspaces (defaults to project/workspace)
+        workspace_root: Root directory for workspaces (defaults to .claude-workspace/ in cwd)
 
     Returns:
         Absolute path to created workspace
     """
     if workspace_root is None:
-        # Use project-relative workspace for local development
-        project_dir = Path(__file__).parent.parent.parent.parent.parent.parent.parent
-        workspace_root = str(project_dir / "examples" / "tutorials" / "10_async" / "10_temporal" / "090_claude_agents_sdk_mvp" / "workspace")
+        # Default to .claude-workspace in current directory
+        # Follows Claude SDK's .claude/ convention
+        workspace_root = os.path.join(os.getcwd(), ".claude-workspace")
 
     workspace_path = os.path.join(workspace_root, task_id)
     os.makedirs(workspace_path, exist_ok=True)