llm name fix

README.md

@@ -172,7 +172,7 @@ uvicorn fastapi_server.server_dashscope:app --reload --host 0.0.0.0 --port 8588
 uvicorn fastapi_server.combined:app --reload --host 0.0.0.0 --port 8500
 ```
 
-You can change the URL by setting `VITE_FRONT_API_BASE_URL` in `frontend/.env` (defaults to `http://127.0.0.1:8500`).
+You can change the URL by setting `VITE_FRONT_API_BASE_URL` in `frontend/.env` (defaults to `/`, i.e. same-origin).
 
 ### Start the development server
 

docker/Dockerfile.frontend

@@ -4,10 +4,16 @@ WORKDIR /app
 
 RUN npm config set registry https://registry.npmmirror.com
 
+# Build-time API base for Vite (must be set before npm run build).
+ARG VITE_FRONT_API_BASE_URL=/
+ENV VITE_FRONT_API_BASE_URL=${VITE_FRONT_API_BASE_URL}
+
 COPY package*.json ./
 RUN npm install
 
 COPY . .
-RUN npm run build
+RUN npm run build && \
+    mkdir -p /opt/frontend_dist && \
+    cp -r dist/. /opt/frontend_dist/
 
-CMD ["ls", "dist"]
+CMD ["sh", "-c", "rm -rf /app/dist/* && cp -r /opt/frontend_dist/. /app/dist && ls /app/dist"]

docker/docker-compose.prod.yml

@@ -25,7 +25,7 @@ services:
       interval: 10s
       timeout: 5s
       retries: 5
-    restart: unless-stopped
+    restart: no #unless-stopped
 
   # Backend API server
   backend:
@@ -52,7 +52,7 @@ services:
     depends_on:
       postgres:
         condition: service_healthy
-    restart: unless-stopped
+    restart: no #unless-stopped
     healthcheck:
       test: ["CMD", "curl", "-f", "http://localhost:8500/health"]
       interval: 30s
@@ -65,6 +65,8 @@ services:
     build:
       context: ../frontend
       dockerfile: ../docker/Dockerfile.frontend
+      args:
+        VITE_FRONT_API_BASE_URL: ${VITE_FRONT_API_BASE_URL:-/}
     volumes:
       - frontend_dist:/app/dist
     networks:
@@ -86,7 +88,7 @@ services:
         condition: service_completed_successfully
       backend:
         condition: service_started
-    restart: unless-stopped
+    restart: no #unless-stopped
 
 volumes:
   postgres_data:

frontend/src/App.tsx

@@ -41,16 +41,24 @@ type EditableAgent = {
   apiKey: string;
   llmName: string;
   actBackend: DeepAgentActBackend;
+  fileBackendConfig: FileBackendConfig;
 };
 
 type AgentChatMessage = {
   id: string;
-  role: "user" | "assistant";
+  role: "user" | "assistant" | "tool";
   content: string;
 };
 
 type ActiveTab = "agents" | "discussions" | "mcp";
 type DeepAgentActBackend = "state_bk" | "local_shell" | "daytona_sandbox";
+
+type FileBackendConfig = {
+  skills_dir: string;
+  rt_skills_dir: string;
+  workspace_dir?: string;
+  api_key?: string;
+};
 type McpTransport = "streamable_http" | "sse" | "stdio";
 type McpEntry = {
   id: string;
@@ -74,7 +82,24 @@ const DEEPAGENT_BACKEND_OPTIONS: Array<{
   { value: "local_shell", label: "local_shell" },
   { value: "daytona_sandbox", label: "daytona_sandbox" },
 ];
-const LOCAL_DASHSCOPE_BASE = "http://127.0.0.1:8500/v1/apps";
+
+const DEFAULT_FILE_BACKEND_CONFIG: Record<DeepAgentActBackend, FileBackendConfig> = {
+  state_bk: {
+    skills_dir: "./assets/skills",
+    rt_skills_dir: "/skills",
+  },
+  local_shell: {
+    skills_dir: "./workspace/skills",
+    rt_skills_dir: "/skills",
+    workspace_dir: "./workspace",
+  },
+  daytona_sandbox: {
+    skills_dir: "./workspace/skills",
+    rt_skills_dir: "",
+    api_key: "",
+  },
+};
+const LOCAL_DASHSCOPE_BASE = "/v1/apps";
 const MCP_TRANSPORT_OPTIONS: McpTransport[] = ["streamable_http", "sse", "stdio"];
 const GRAPH_ARCH_IMAGE_MODULES = import.meta.glob(
   "../assets/images/graph_arch/*.{png,jpg,jpeg,webp,gif}",
@@ -427,6 +452,28 @@ function createConversationId(): string {
   return `conv-${Date.now()}-${Math.random().toString(36).slice(2, 8)}`;
 }
 
+function mapConversationMessageToAgentChatMessage(
+  message: ConversationMessageItem
+): AgentChatMessage | null {
+  const type = (message.message_type || "").toLowerCase();
+  let role: AgentChatMessage["role"] | null = null;
+  if (type === "human" || type === "user") {
+    role = "user";
+  } else if (type === "ai" || type === "assistant") {
+    role = "assistant";
+  } else if (type === "tool") {
+    role = "tool";
+  }
+  if (!role) {
+    return null;
+  }
+  return {
+    id: `${message.sequence_number}-${message.created_at}-${role}`,
+    role,
+    content: message.content || "",
+  };
+}
+
 function normalizeDeepAgentActBackend(value: unknown): DeepAgentActBackend {
   if (value === "local_shell" || value === "localshell") {
     return "local_shell";
@@ -440,9 +487,68 @@ function normalizeDeepAgentActBackend(value: unknown): DeepAgentActBackend {
   return DEFAULT_DEEPAGENT_ACT_BACKEND;
 }
 
+function getDefaultFileBackendConfig(
+  backend: DeepAgentActBackend
+): FileBackendConfig {
+  return { ...DEFAULT_FILE_BACKEND_CONFIG[backend] };
+}
+
+function isRecord(value: unknown): value is Record<string, unknown> {
+  return typeof value === "object" && value !== null && !Array.isArray(value);
+}
+
+function readOptionalString(
+  record: Record<string, unknown>,
+  key: keyof FileBackendConfig
+): string | undefined {
+  const value = record[key];
+  return typeof value === "string" ? value : undefined;
+}
+
+function getDeepAgentEditorState(config: GraphConfigReadResponse): {
+  actBackend: DeepAgentActBackend;
+  fileBackendConfig: FileBackendConfig;
+} {
+  const graphParams = isRecord(config.graph_params) ? config.graph_params : {};
+  const actBackend = normalizeDeepAgentActBackend(graphParams.act_bkend);
+  const defaults = getDefaultFileBackendConfig(actBackend);
+  const rawFileBackendConfig = isRecord(graphParams.file_backend_config)
+    ? graphParams.file_backend_config
+    : null;
+
+  if (!rawFileBackendConfig) {
+    return {
+      actBackend,
+      fileBackendConfig: defaults,
+    };
+  }
+
+  return {
+    actBackend,
+    fileBackendConfig: {
+      ...defaults,
+      ...(readOptionalString(rawFileBackendConfig, "skills_dir") !== undefined
+        ? { skills_dir: readOptionalString(rawFileBackendConfig, "skills_dir") as string }
+        : {}),
+      ...(readOptionalString(rawFileBackendConfig, "rt_skills_dir") !== undefined
+        ? { rt_skills_dir: readOptionalString(rawFileBackendConfig, "rt_skills_dir") as string }
+        : {}),
+      ...(readOptionalString(rawFileBackendConfig, "workspace_dir") !== undefined
+        ? { workspace_dir: readOptionalString(rawFileBackendConfig, "workspace_dir") as string }
+        : {}),
+      ...(readOptionalString(rawFileBackendConfig, "api_key") !== undefined
+        ? { api_key: readOptionalString(rawFileBackendConfig, "api_key") as string }
+        : {}),
+    },
+  };
+}
+
 function buildGraphParams(editor: EditableAgent): Record<string, unknown> {
   if (editor.graphId === "deepagent") {
-    return { act_bkend: editor.actBackend };
+    return { 
+      act_bkend: editor.actBackend,
+      file_backend_config: editor.fileBackendConfig,
+    };
   }
   return {};
 }
@@ -451,6 +557,7 @@ function toEditable(
   config: GraphConfigReadResponse,
   draft: boolean
 ): EditableAgent {
+  const deepAgentState = getDeepAgentEditorState(config);
   return {
     id: draft
       ? `draft-${Date.now()}-${Math.random().toString(36).slice(2, 6)}`
@@ -464,7 +571,8 @@ function toEditable(
     prompts: config.prompt_dict || {},
     apiKey: config.api_key || DEFAULT_API_KEY,
     llmName: DEFAULT_LLM_NAME,
-    actBackend: DEFAULT_DEEPAGENT_ACT_BACKEND,
+    actBackend: deepAgentState.actBackend,
+    fileBackendConfig: deepAgentState.fileBackendConfig,
   };
 }
 
@@ -757,6 +865,10 @@ export default function App() {
             graphId === "deepagent"
               ? prev.actBackend || DEFAULT_DEEPAGENT_ACT_BACKEND
               : DEFAULT_DEEPAGENT_ACT_BACKEND,
+          fileBackendConfig:
+            graphId === "deepagent"
+              ? prev.fileBackendConfig || getDefaultFileBackendConfig(DEFAULT_DEEPAGENT_ACT_BACKEND)
+              : getDefaultFileBackendConfig(DEFAULT_DEEPAGENT_ACT_BACKEND),
         };
         if (next.isDraft) {
           setDraftAgents((drafts) => drafts.map((draft) => (draft.id === next.id ? next : draft)));
@@ -790,6 +902,24 @@ export default function App() {
     setEditorAndSyncDraft((prev) => ({ ...prev, [key]: value }));
   }
 
+  function updateActBackend(newBackend: DeepAgentActBackend): void {
+    setEditorAndSyncDraft((prev) => ({
+      ...prev,
+      actBackend: newBackend,
+    fileBackendConfig: getDefaultFileBackendConfig(newBackend),
+    }));
+  }
+
+  function updateFileBackendConfig(key: keyof FileBackendConfig, value: string): void {
+    setEditorAndSyncDraft((prev) => ({
+      ...prev,
+      fileBackendConfig: {
+        ...prev.fileBackendConfig,
+        [key]: value,
+      },
+    }));
+  }
+
   function updatePrompt(key: string, value: string): void {
     setEditorAndSyncDraft((prev) => ({
       ...prev,
@@ -1119,6 +1249,7 @@ export default function App() {
 
   async function sendAgentChatMessage(): Promise<void> {
     const pipelineId = (chatPipelineId || "").trim();
+    const conversationId = chatConversationId;
     const message = chatInput.trim();
     if (!pipelineId || !message || chatSending) {
       return;
@@ -1148,7 +1279,7 @@ export default function App() {
     try {
       await streamAgentChatResponse({
         appId: pipelineId,
-        sessionId: chatConversationId,
+        sessionId: conversationId,
         apiKey: authKey,
         message,
         signal: controller.signal,
@@ -1165,6 +1296,34 @@ export default function App() {
           );
         },
       });
+      // Some runtimes namespace thread ids as "<pipeline_id>:<session_id>" when persisting.
+      // Try both IDs and fail soft so a successful streamed reply never turns into a UI error.
+      const candidateConversationIds = [
+        conversationId,
+        `${pipelineId}:${conversationId}`,
+      ];
+      let reloaded = false;
+      for (const candidateId of candidateConversationIds) {
+        try {
+          const storedMessages = await getPipelineConversationMessages(
+            pipelineId,
+            candidateId
+          );
+          const normalizedMessages = storedMessages
+            .map(mapConversationMessageToAgentChatMessage)
+            .filter((item): item is AgentChatMessage => item !== null);
+          if (normalizedMessages.length > 0) {
+            setChatMessages(normalizedMessages);
+            reloaded = true;
+            break;
+          }
+        } catch {
+          // Ignore refresh failures; keep streamed content visible.
+        }
+      }
+      if (!reloaded) {
+        // Keep existing streamed messages without surfacing a false error state.
+      }
     } catch (error) {
       if ((error as Error).message === "Request cancelled") {
         setChatMessages((prev) =>
@@ -1404,15 +1563,13 @@ export default function App() {
                 </label>
 
                 {editor.graphId === "deepagent" ? (
+                  <>
                     <label>
                       act_bkend
                       <select
                         value={editor.actBackend}
                         onChange={(e) =>
-                        updateEditor(
-                          "actBackend",
-                          normalizeDeepAgentActBackend(e.target.value)
-                        )
+                          updateActBackend(normalizeDeepAgentActBackend(e.target.value))
                         }
                         disabled={busy}
                       >
@@ -1423,6 +1580,52 @@ export default function App() {
                         ))}
                       </select>
                     </label>
+
+                    <div className="file-backend-config">
+                      <h3>File Backend Config</h3>
+                      {editor.actBackend === "daytona_sandbox" ? (
+                        <label>
+                          api_key
+                          <input
+                            type="password"
+                            value={editor.fileBackendConfig.api_key || ""}
+                            onChange={(e) => updateFileBackendConfig("api_key", e.target.value)}
+                            placeholder="Daytona API key"
+                            disabled={busy}
+                          />
+                        </label>
+                      ) : null}
+                      {editor.actBackend === "local_shell" ? (
+                        <label>
+                          workspace_dir
+                          <input
+                            value={editor.fileBackendConfig.workspace_dir || ""}
+                            onChange={(e) => updateFileBackendConfig("workspace_dir", e.target.value)}
+                            placeholder="./workspace"
+                            disabled={busy}
+                          />
+                        </label>
+                      ) : null}
+                      <label>
+                        skills_dir
+                        <input
+                          value={editor.fileBackendConfig.skills_dir || ""}
+                          onChange={(e) => updateFileBackendConfig("skills_dir", e.target.value)}
+                          placeholder="./assets/skills"
+                          disabled={busy}
+                        />
+                      </label>
+                      <label>
+                        rt_skills_dir
+                        <input
+                          value={editor.fileBackendConfig.rt_skills_dir || ""}
+                          onChange={(e) => updateFileBackendConfig("rt_skills_dir", e.target.value)}
+                          placeholder="/skills"
+                          disabled={busy}
+                        />
+                      </label>
+                    </div>
+                  </>
                 ) : null}
 
                 <div className="prompt-section">
@@ -1755,9 +1958,15 @@ export default function App() {
                 chatMessages.map((message) => (
                   <article
                     key={message.id}
-                    className={`chat-modal-message ${message.role === "assistant" ? "assistant" : "user"}`}
+                    className={`chat-modal-message ${message.role}`}
                   >
-                    <strong>{message.role === "assistant" ? "Agent" : "You"}</strong>
+                    <strong>
+                      {message.role === "assistant"
+                        ? "Agent"
+                        : message.role === "tool"
+                          ? "Tool"
+                          : "You"}
+                    </strong>
                     <div className="chat-message-content">
                       <ReactMarkdown remarkPlugins={[remarkGfm]}>
                         {message.content || (chatSending && message.role === "assistant" ? "..." : "")}

frontend/src/api/frontApis.ts

@@ -19,8 +19,7 @@ import type {
   RuntimeAuthInfoResponse,
 } from "../types";
 
-const API_BASE_URL =
-  import.meta.env.VITE_FRONT_API_BASE_URL?.trim() || "http://127.0.0.1:8500";
+const API_BASE_URL = import.meta.env.VITE_FRONT_API_BASE_URL?.trim() || "/";
 
 export function joinApiUrl(baseUrl: string, path: string): string {
   const normalizedPath = path.startsWith("/") ? path : `/${path}`;

frontend/src/styles.css

@@ -224,6 +224,7 @@ button:disabled {
 }
 
 .prompt-section,
+.file-backend-config,
 .run-info {
   border: 1px solid #dbe2ea;
   border-radius: 10px;
@@ -232,6 +233,7 @@ button:disabled {
 }
 
 .prompt-section h3,
+.file-backend-config h3,
 .run-info h3 {
   margin-top: 0;
 }
@@ -609,6 +611,10 @@ button:disabled {
   border-left: 3px solid #26a269;
 }
 
+.chat-modal-message.tool {
+  border-left: 3px solid #8e6bd8;
+}
+
 .chat-modal-message p {
   margin: 6px 0 0 0;
   white-space: pre-wrap;

frontend/src/types.ts

@@ -23,6 +23,7 @@ export type GraphConfigReadResponse = {
   tool_keys: string[];
   prompt_dict: Record<string, string>;
   api_key: string;
+  graph_params?: Record<string, unknown>;
 };
 
 export type GraphConfigUpsertRequest = {

lang_agent/config/__init__.py

@@ -4,6 +4,7 @@ from lang_agent.config.core_config import (
     LLMKeyConfig,
     LLMNodeConfig,
     load_tyro_conf,
+    resolve_llm_api_key,
 )
 
 from lang_agent.config.constants import (

lang_agent/config/core_config.py

@@ -10,6 +10,20 @@ from dotenv import load_dotenv
 
 load_dotenv()
 
+
+def resolve_llm_api_key(api_key: Optional[str]) -> Optional[str]:
+    """Resolve the API key for OpenAI-compatible providers."""
+    if api_key not in (None, "", "wrong-key"):
+        resolved_key = api_key
+    else:
+        resolved_key = os.environ.get("ALI_API_KEY") or os.environ.get("OPENAI_API_KEY")
+
+    # Some OpenAI-compatible integrations still read OPENAI_API_KEY from env.
+    if resolved_key and not os.environ.get("OPENAI_API_KEY"):
+        os.environ["OPENAI_API_KEY"] = resolved_key
+
+    return resolved_key
+
 ## NOTE: base classes taken from nerfstudio
 class PrintableConfig:
     """
@@ -99,12 +113,12 @@ class LLMKeyConfig(InstantiateConfig):
     """api key for llm"""
 
     def __post_init__(self):
-        if self.api_key == "wrong-key" or self.api_key is None:
-            self.api_key = os.environ.get("ALI_API_KEY")
+        original_api_key = self.api_key
+        self.api_key = resolve_llm_api_key(self.api_key)
         if self.api_key is None:
-                logger.error(f"no ALI_API_KEY provided for embedding")
-            else:
-                logger.info("ALI_API_KEY loaded from environ")
+            logger.error("no ALI_API_KEY or OPENAI_API_KEY provided for embedding")
+        elif original_api_key in (None, "", "wrong-key"):
+            logger.info("LLM API key loaded from environment")
 
 
 @dataclass

lang_agent/fastapi_server/front_apis.py

@@ -20,6 +20,7 @@ from lang_agent.config.constants import (
     MCP_CONFIG_DEFAULT_CONTENT,
     PIPELINE_REGISTRY_PATH,
 )
+from lang_agent.config.core_config import load_tyro_conf
 from lang_agent.front_api.build_server_utils import (
     GRAPH_BUILD_FNCS,
     update_pipeline_registry,
@@ -55,6 +56,7 @@ class GraphConfigReadResponse(BaseModel):
     tool_keys: List[str]
     prompt_dict: Dict[str, str]
     api_key: str = Field(default="")
+    graph_params: Dict[str, Any] = Field(default_factory=dict)
 
 
 class GraphConfigListItem(BaseModel):
@@ -325,6 +327,81 @@ def _normalize_pipeline_spec(pipeline_id: str, spec: Dict[str, Any]) -> Pipeline
     )
 
 
+def _resolve_config_path(config_file: str) -> str:
+    if osp.isabs(config_file):
+        return config_file
+    return osp.join(_PROJECT_ROOT, config_file)
+
+
+def _normalize_deepagent_backend_name(file_backend_config: Any) -> Optional[str]:
+    if file_backend_config is None:
+        return None
+
+    type_names = {
+        type(file_backend_config).__name__.lower(),
+        getattr(getattr(file_backend_config, "_target", None), "__name__", "").lower(),
+    }
+    if any("statebk" in name for name in type_names):
+        return "state_bk"
+    if any("localshell" in name for name in type_names):
+        return "local_shell"
+    if any("daytona" in name for name in type_names):
+        return "daytona_sandbox"
+    return None
+
+
+def _extract_graph_params_from_config(graph_id: Optional[str], loaded_cfg: Any) -> Dict[str, Any]:
+    if graph_id != "deepagent":
+        return {}
+
+    graph_config = getattr(loaded_cfg, "graph_config", None)
+    file_backend_config = getattr(graph_config, "file_backend_config", None)
+    if file_backend_config is None:
+        return {}
+
+    graph_params: Dict[str, Any] = {}
+    act_bkend = _normalize_deepagent_backend_name(file_backend_config)
+    if act_bkend:
+        graph_params["act_bkend"] = act_bkend
+
+    serialized_backend_config: Dict[str, Any] = {}
+    for key in ("skills_dir", "rt_skills_dir", "workspace_dir", "api_key"):
+        value = getattr(file_backend_config, key, None)
+        if value is not None:
+            serialized_backend_config[key] = value
+
+    if serialized_backend_config:
+        graph_params["file_backend_config"] = serialized_backend_config
+
+    return graph_params
+
+
+def _load_graph_params_for_pipeline(
+    pipeline_id: str, graph_id: Optional[str]
+) -> Dict[str, Any]:
+    try:
+        registry = _read_pipeline_registry()
+        pipeline_spec = registry.get("pipelines", {}).get(pipeline_id, {})
+        config_file = ""
+        if isinstance(pipeline_spec, dict):
+            config_file = str(pipeline_spec.get("config_file") or "").strip()
+        if not config_file:
+            fallback = osp.join(_PROJECT_ROOT, "configs", "pipelines", f"{pipeline_id}.yaml")
+            if osp.exists(fallback):
+                config_file = fallback
+        if not config_file:
+            return {}
+
+        config_path = _resolve_config_path(config_file)
+        if not osp.exists(config_path):
+            return {}
+
+        loaded_cfg = load_tyro_conf(config_path)
+        return _extract_graph_params_from_config(graph_id, loaded_cfg)
+    except Exception:
+        return {}
+
+
 def _normalize_api_key_policy(api_key: str, policy: Dict[str, Any]) -> ApiKeyPolicyItem:
     if not isinstance(policy, dict):
         raise ValueError(f"api key policy for '{api_key}' must be an object")
@@ -428,6 +505,9 @@ async def get_default_graph_config(pipeline_id: str):
         tool_keys=tool_keys,
         prompt_dict=prompt_dict,
         api_key=(active.get("api_key") or ""),
+        graph_params=_load_graph_params_for_pipeline(
+            pipeline_id, active.get("graph_id")
+        ),
     )
 
 
@@ -466,6 +546,9 @@ async def get_graph_config(pipeline_id: str, prompt_set_id: str):
         tool_keys=tool_keys,
         prompt_dict=prompt_dict,
         api_key=(meta.get("api_key") or ""),
+        graph_params=_load_graph_params_for_pipeline(
+            pipeline_id, meta.get("graph_id")
+        ),
     )
 
 

lang_agent/front_api/build_server_utils.py

@@ -1,4 +1,4 @@
-from typing import Any, Dict, List, Literal
+from typing import Any, Dict, List, Literal, Optional
 import os
 import os.path as osp
 import subprocess
@@ -77,6 +77,8 @@ def build_route(
     cmd_opt = [
         "--pipeline.pipeline-id",
         pipeline_id,
+        "--pipeline.llm-name", 
+        llm_name,
         "route",  # ------------
         "--llm-name",
         llm_name,
@@ -125,6 +127,8 @@ def build_react(
     cmd_opt = [
         "--pipeline.pipeline-id",
         pipeline_id,
+        "--pipeline.llm-name", 
+        llm_name,
         "react",  # ------------
         "--llm-name",
         llm_name,
@@ -158,6 +162,7 @@ def build_deep_agent(
         "daytona_sandbox",
         "daytonasandbox",
     ] = "state_bk",
+    file_backend_config: Optional[Dict[str, Any]] = None,
     **_: Any,
 ):
     backend_subcommand = _DEEP_AGENT_BACKEND_ALIASES.get(act_bkend)
@@ -170,6 +175,8 @@ def build_deep_agent(
     cmd_opt = [
         "--pipeline.pipeline-id",
         pipeline_id,
+        "--pipeline.llm-name", 
+        llm_name,
         "deepagent",
         "--llm-name",
         llm_name,
@@ -185,11 +192,26 @@ def build_deep_agent(
         cmd_opt.extend(
             ["--tool-manager-config.client-tool-manager.tool-keys", *tool_keys]
         )
-        # Same greedy-list behavior as `build_route`; terminate before backend subcommand.
         cmd_opt.extend(["--pipeline-id", pipeline_id])
 
     cmd_opt.append(backend_subcommand)
 
+    if file_backend_config:
+        if "skills_dir" in file_backend_config and file_backend_config["skills_dir"]:
+            cmd_opt.extend(["--skills-dir", file_backend_config["skills_dir"]])
+        if (
+            "rt_skills_dir" in file_backend_config
+            and file_backend_config["rt_skills_dir"]
+        ):
+            cmd_opt.extend(["--rt-skills-dir", file_backend_config["rt_skills_dir"]])
+        if (
+            "workspace_dir" in file_backend_config
+            and file_backend_config["workspace_dir"]
+        ):
+            cmd_opt.extend(["--workspace-dir", file_backend_config["workspace_dir"]])
+        if "api_key" in file_backend_config and file_backend_config["api_key"]:
+            cmd_opt.extend(["--api-key", file_backend_config["api_key"]])
+
     return _build_and_load_pipeline_config(pipeline_id, pipeline_config_dir, cmd_opt)
 
 

lang_agent/fs_bkends/base.py

@@ -1,8 +1,10 @@
-from dataclasses import dataclass, field, is_dataclass
+import os
+from dataclasses import dataclass
 from typing import Any
-import tyro
-import os.path as osp
 from abc import ABC, abstractmethod
+from loguru import logger
+
+from lang_agent.config import InstantiateConfig
 
 
 class BaseFilesystemBackend(ABC):
@@ -26,3 +28,24 @@ class BaseFilesystemBackend(ABC):
             return {"skills" : [self.config.rt_skills_dir]}
         else:
             return {}
+
+
+@dataclass
+class FilesystemBackendConfig(InstantiateConfig):
+    """
+    Shared filesystem backend config behavior.
+    If subclasses define these fields, this hook ensures they exist:
+      - skills_dir
+      - workspace_dir
+    """
+
+    def _ensure_dir_if_present(self, attr_name: str) -> None:
+        path = getattr(self, attr_name, None)
+        if not isinstance(path, str) or not path.strip():
+            return
+        os.makedirs(path, exist_ok=True)
+        logger.info(f"Ensured {attr_name} exists: {path}")
+
+    def __post_init__(self) -> None:
+        self._ensure_dir_if_present("skills_dir")
+        self._ensure_dir_if_present("workspace_dir")

lang_agent/fs_bkends/daytona_sandbox.py

@@ -8,13 +8,12 @@ from loguru import logger
 from daytona import Daytona, DaytonaConfig, FileUpload
 from langchain_daytona import DaytonaSandbox
 
-from lang_agent.config import InstantiateConfig
-from lang_agent.fs_bkends import BaseFilesystemBackend
+from lang_agent.fs_bkends.base import BaseFilesystemBackend, FilesystemBackendConfig
 
 
 @tyro.conf.configure(tyro.conf.SuppressFixed)
 @dataclass
-class DaytonaSandboxConfig(InstantiateConfig):
+class DaytonaSandboxConfig(FilesystemBackendConfig):
     _target: Type = field(default_factory=lambda: DaytonaSandboxBk)
 
     api_key: Optional[str] = None
@@ -27,6 +26,7 @@ class DaytonaSandboxConfig(InstantiateConfig):
     """runtime skills path inside the sandbox (auto-set from sandbox workdir)"""
 
     def __post_init__(self):
+        super().__post_init__()
         if self.api_key is None:
             self.api_key = os.environ.get("DAYTONA_API_KEY")
             if self.api_key is None:

lang_agent/fs_bkends/localshell.py

@@ -1,21 +1,16 @@
-from dataclasses import dataclass, field, is_dataclass
-from typing import Type, TypedDict, Literal, Dict, List, Tuple, Optional
+from dataclasses import dataclass, field
+from typing import Type
 import tyro
-import os.path as osp
-from abc import ABC, abstractmethod
-import glob
 from loguru import logger
 
-from deepagents.backends.utils import create_file_data
 from deepagents.backends import LocalShellBackend
 
-from lang_agent.config import InstantiateConfig
-from lang_agent.fs_bkends import BaseFilesystemBackend
+from lang_agent.fs_bkends.base import BaseFilesystemBackend, FilesystemBackendConfig
 
 
 @tyro.conf.configure(tyro.conf.SuppressFixed)
 @dataclass
-class LocalShellConfig(InstantiateConfig):
+class LocalShellConfig(FilesystemBackendConfig):
     _target:Type = field(default_factory=lambda:LocalShell)
 
     workspace_dir:str = "./workspace"

lang_agent/fs_bkends/statebk.py

@@ -1,16 +1,14 @@
-from dataclasses import dataclass, field, is_dataclass
-from typing import Type, TypedDict, Literal, Dict, List, Tuple, Optional
+from dataclasses import dataclass, field
+from typing import Type
 import tyro
 import os.path as osp
-from abc import ABC, abstractmethod
 import glob
 from loguru import logger
 
 from deepagents.backends.utils import create_file_data
 from deepagents.backends import StateBackend
 
-from lang_agent.config import InstantiateConfig
-from lang_agent.fs_bkends import BaseFilesystemBackend
+from lang_agent.fs_bkends.base import BaseFilesystemBackend, FilesystemBackendConfig
 
 def read_as_utf8(file_path:str):
     with open(file_path, "r", encoding="utf-8") as f:
@@ -31,7 +29,7 @@ def build_skill_fs_dict(skill_dir:str, virt_path:str="/skills"):
 
 @tyro.conf.configure(tyro.conf.SuppressFixed)
 @dataclass
-class StateBkConfig(InstantiateConfig):
+class StateBkConfig(FilesystemBackendConfig):
     _target:Type = field(default_factory=lambda:StateBk)
 
     skills_dir:str = "./assets/skills"
@@ -40,10 +38,6 @@ class StateBkConfig(InstantiateConfig):
     rt_skills_dir:str = "/skills"
     """path to directory with skills in runtime directory"""
 
-    def __post_init__(self):
-        err_msg = f"{self.skills_dir} does not exist"
-        assert osp.exists(self.skills_dir), err_msg
-
 
 class StateBk(BaseFilesystemBackend):
     def __init__(self, config:StateBkConfig):

lang_agent/pipeline.py

@@ -13,7 +13,7 @@ from langchain_core.messages import SystemMessage, HumanMessage, BaseMessage
 from langchain.agents import create_agent
 from langgraph.checkpoint.memory import MemorySaver
 
-from lang_agent.config import LLMNodeConfig, load_tyro_conf
+from lang_agent.config import LLMNodeConfig, load_tyro_conf, resolve_llm_api_key
 from lang_agent.graphs import AnnotatedGraph, ReactGraphConfig, RoutingConfig
 from lang_agent.base import GraphBase
 from lang_agent.components import conv_store
@@ -104,7 +104,13 @@ class Pipeline:
                 if self.config.base_url is not None
                 else self.config.graph_config.base_url
             )
-            self.config.graph_config.api_key = self.config.api_key
+            pipeline_api_key = resolve_llm_api_key(self.config.api_key)
+            graph_api_key = resolve_llm_api_key(
+                getattr(self.config.graph_config, "api_key", None)
+            )
+            resolved_api_key = pipeline_api_key or graph_api_key
+            self.config.api_key = resolved_api_key
+            self.config.graph_config.api_key = resolved_api_key
 
         self.graph: GraphBase = self.config.graph_config.setup()
 

nginx.conf

@@ -21,6 +21,15 @@ http {
         root /usr/share/nginx/html;
         index index.html;
 
+        # Always revalidate the SPA entrypoint so clients pick up the latest
+        # hashed JS bundle after redeploys.
+        location = /index.html {
+            add_header Cache-Control "no-store, no-cache, must-revalidate, proxy-revalidate" always;
+            add_header Pragma "no-cache" always;
+            add_header Expires "0" always;
+            try_files $uri =404;
+        }
+
         # Serve frontend static files
         location / {
             try_files $uri $uri/ /index.html;