Merge branch 'release-1.10.0' into LE-1080

Author: olayinkaadelakun

src/backend/tests/unit/test_logger.py

@@ -33,6 +33,7 @@
     setup_gunicorn_logger,
     setup_uvicorn_logger,
 )
+from loguru import logger as loguru_logger
 
 
 class TestConfigure:
@@ -104,6 +105,29 @@ def test_configure_with_log_file(self):
                 if isinstance(handler, logging.handlers.RotatingFileHandler):
                     logging.root.removeHandler(handler)
 
+    def test_configure_routes_loguru_messages_to_log_file(self):
+        """Test configure() routes Loguru messages through Langflow logging."""
+        with tempfile.TemporaryDirectory() as tmp_dir:
+            log_file_path = Path(tmp_dir) / "langflow.log"
+
+            for handler in logging.root.handlers[:]:
+                if isinstance(handler, logging.handlers.RotatingFileHandler):
+                    logging.root.removeHandler(handler)
+
+            try:
+                configure(log_level="INFO", log_file=log_file_path, cache=False)
+                loguru_logger.info("Custom component log message")
+
+                for handler in logging.root.handlers:
+                    if hasattr(handler, "flush"):
+                        handler.flush()
+
+                assert "Custom component log message" in log_file_path.read_text()
+            finally:
+                for handler in logging.root.handlers[:]:
+                    if isinstance(handler, logging.handlers.RotatingFileHandler):
+                        logging.root.removeHandler(handler)
+
     def test_configure_with_invalid_log_file_path(self):
         """Test configure() with invalid log file path falls back to cache dir."""
         invalid_path = Path("/nonexistent/directory/log.txt")

src/frontend/src/pages/MainPage/pages/deploymentsPage/__tests__/step-attach-flows-version-panel.test.tsx

@@ -59,11 +59,13 @@ const defaultProps = {
   selectedFlow: selectedFlow as FlowType | undefined,
   versions,
   isLoadingVersions: false,
+  isCreatingDraftVersion: false,
   selectedVersionByFlow: new Map<
     string,
     { versionId: string; versionTag: string }
   >(),
   onAttach: jest.fn(),
+  onCreateFromDraft: jest.fn(),
 };
 
 function renderPanel(overrides: Partial<typeof defaultProps> = {}) {
@@ -106,7 +108,21 @@ describe("Loading state", () => {
 describe("No versions found", () => {
   it("shows empty state when no versions exist", () => {
     renderPanel({ versions: [] });
-    expect(screen.getByText("No versions found")).toBeInTheDocument();
+    expect(
+      screen.getByText(
+        "Deploy this flow by creating a version from current Draft",
+      ),
+    ).toBeInTheDocument();
+    expect(screen.getByTestId("create-version-from-draft")).toBeInTheDocument();
+  });
+
+  it("calls onCreateFromDraft when clicking empty-state CTA", async () => {
+    const user = userEvent.setup();
+    const onCreateFromDraft = jest.fn();
+    renderPanel({ versions: [], onCreateFromDraft });
+
+    await user.click(screen.getByTestId("create-version-from-draft"));
+    expect(onCreateFromDraft).toHaveBeenCalled();
   });
 });
 

src/frontend/src/pages/MainPage/pages/deploymentsPage/__tests__/step-attach-flows.test.tsx

@@ -102,6 +102,7 @@ let mockVersionsData: {
   }>;
 } | null = null;
 let mockIsLoadingVersions = false;
+const mockCreateSnapshot = jest.fn();
 
 jest.mock(
   "@/controllers/API/queries/flow-version/use-get-flow-versions",
@@ -113,6 +114,16 @@ jest.mock(
   }),
 );
 
+jest.mock(
+  "@/controllers/API/queries/flow-version/use-post-create-snapshot",
+  () => ({
+    usePostCreateSnapshot: () => ({
+      mutateAsync: mockCreateSnapshot,
+      isPending: false,
+    }),
+  }),
+);
+
 const mockDetectEnvVars = jest.fn().mockResolvedValue({ variables: [] });
 
 jest.mock(
@@ -223,6 +234,10 @@ beforeEach(() => {
     ],
   };
   mockIsLoadingVersions = false;
+  mockCreateSnapshot.mockResolvedValue({
+    id: "ver-new",
+    version_tag: "v3",
+  });
 });
 
 // ---------------------------------------------------------------------------
@@ -304,7 +319,33 @@ describe("Version panel", () => {
   it("shows empty state when no versions available", () => {
     mockVersionsData = { entries: [] };
     render(<StepAttachFlows />);
-    expect(screen.getByText("No versions found")).toBeInTheDocument();
+    expect(
+      screen.getByText(
+        "Deploy this flow by creating a version from current Draft",
+      ),
+    ).toBeInTheDocument();
+  });
+
+  it("creates version from draft and opens connection panel", async () => {
+    const user = userEvent.setup();
+    mockVersionsData = { entries: [] };
+    render(<StepAttachFlows />);
+
+    await user.click(screen.getByTestId("create-version-from-draft"));
+
+    await waitFor(() => {
+      expect(mockCreateSnapshot).toHaveBeenCalledWith({ flowId: "flow-1" });
+    });
+
+    await waitFor(() => {
+      expect(
+        screen.getByText("Select or Create New Connection"),
+      ).toBeInTheDocument();
+    });
+
+    expect(mockDetectEnvVars).toHaveBeenCalledWith({
+      flow_version_ids: ["ver-new"],
+    });
   });
 
   it("shows ATTACHED badge for already-attached versions", () => {

src/frontend/src/pages/MainPage/pages/deploymentsPage/__tests__/step-type.test.tsx

@@ -241,6 +241,20 @@ describe("Name input", () => {
     );
   });
 
+  it("does not show available state when format error is active", () => {
+    mockDeploymentName = "1";
+    mockHasDeploymentNameFormatError = true;
+
+    render(<StepType />);
+
+    expect(
+      screen.getByText("Agent name must start with a letter."),
+    ).toBeInTheDocument();
+    expect(
+      screen.queryByText("Agent name is available."),
+    ).not.toBeInTheDocument();
+  });
+
   it("does not show validation error for empty name", () => {
     render(<StepType />);
     expect(

src/frontend/src/pages/MainPage/pages/deploymentsPage/components/step-attach-flows-version-panel.tsx

@@ -1,6 +1,7 @@
 import { memo } from "react";
 import VersionLabel from "@/components/common/versionLabelComponent";
 import { Badge } from "@/components/ui/badge";
+import { Button } from "@/components/ui/button";
 import type { FlowType } from "@/types/flow";
 import type { FlowVersionEntry } from "@/types/flow/version";
 import { cn } from "@/utils/utils";
@@ -19,14 +20,18 @@ export const VersionPanel = memo(function VersionPanel({
   selectedFlow,
   versions,
   isLoadingVersions,
+  isCreatingDraftVersion,
   selectedVersionByFlow,
   onAttach,
+  onCreateFromDraft,
 }: {
   selectedFlow: FlowType | undefined;
   versions: FlowVersionEntry[];
   isLoadingVersions: boolean;
+  isCreatingDraftVersion: boolean;
   selectedVersionByFlow: Map<string, { versionId: string; versionTag: string }>;
   onAttach: (versionId: string) => void;
+  onCreateFromDraft: () => void;
 }) {
   if (!selectedFlow) {
     return (
@@ -53,8 +58,19 @@ export const VersionPanel = memo(function VersionPanel({
           )}
 
           {!isLoadingVersions && versions.length === 0 && (
-            <div className="flex items-center justify-center py-8 text-sm text-muted-foreground">
-              No versions found
+            <div className="flex flex-col items-center justify-center gap-4 rounded-xl border border-dashed border-border bg-muted/30 px-6 py-8 text-center">
+              <p className="max-w-sm text-sm text-muted-foreground">
+                Deploy this flow by creating a version from current Draft
+              </p>
+              <Button
+                onClick={onCreateFromDraft}
+                loading={isCreatingDraftVersion}
+                disabled={isCreatingDraftVersion}
+                ignoreTitleCase
+                data-testid="create-version-from-draft"
+              >
+                Create from Draft
+              </Button>
             </div>
           )}
 

src/frontend/src/pages/MainPage/pages/deploymentsPage/components/step-attach-flows.tsx

@@ -2,6 +2,7 @@ import { useCallback, useEffect, useMemo, useRef, useState } from "react";
 import { useParams } from "react-router-dom";
 import { useGetDeploymentConfigs } from "@/controllers/API/queries/deployments/use-get-deployment-configs";
 import { useGetFlowVersions } from "@/controllers/API/queries/flow-version/use-get-flow-versions";
+import { usePostCreateSnapshot } from "@/controllers/API/queries/flow-version/use-post-create-snapshot";
 import { useGetRefreshFlowsQuery } from "@/controllers/API/queries/flows/use-get-refresh-flows-query";
 import { useGetGlobalVariables } from "@/controllers/API/queries/variables";
 import { usePostDetectEnvVars } from "@/controllers/API/queries/variables/use-post-detect-env-vars";
@@ -25,7 +26,6 @@ export default function StepAttachFlows() {
     setConnections,
     selectedVersionByFlow,
     handleSelectVersion: onSelectVersion,
-    toolNameByFlow,
     setToolNameByFlow,
     attachedConnectionByFlow,
     setAttachedConnectionByFlow: onAttachConnection,
@@ -157,13 +157,13 @@ export default function StepAttachFlows() {
   });
 
   const { mutateAsync: detectEnvVars } = usePostDetectEnvVars();
+  const { mutateAsync: createSnapshot, isPending: isCreatingDraftVersion } =
+    usePostCreateSnapshot();
   const { data: globalVariables } = useGetGlobalVariables();
   const globalVariableOptions = (globalVariables ?? []).map((v) => v.name);
 
   // When a flow+version are pre-selected from outside (e.g., canvas deploy button),
   // auto-advance to the connections panel and detect env vars for the pre-selected version.
-  // biome-ignore lint/correctness/useExhaustiveDependencies: intentionally run only on mount
-  // eslint-disable-next-line react-hooks/exhaustive-deps
   useEffect(() => {
     const preSelected = initialFlowId
       ? selectedVersionByFlow.get(initialFlowId)
@@ -197,18 +197,16 @@ export default function StepAttachFlows() {
 
   const selectedFlow = flows.find((f) => f.id === effectiveFlowId);
 
-  const handleAttachFlow = useCallback(
-    async (versionId: string) => {
-      if (!effectiveFlowId) return;
-      const version = versions.find((v) => v.id === versionId);
+  const openConnectionPanelForVersion = useCallback(
+    async (flowId: string, versionId: string, versionTag: string) => {
       // Don't commit to context yet — wait for connection step to complete.
       setPendingAttachment({
-        flowId: effectiveFlowId,
+        flowId,
         versionId,
-        versionTag: version?.version_tag ?? "",
+        versionTag,
       });
       setRightPanel("connections");
-      initConnectionsForFlow(effectiveFlowId);
+      initConnectionsForFlow(flowId);
 
       // Auto-detect global variable references via the backend detection endpoint
       try {
@@ -225,15 +223,51 @@ export default function StepAttachFlows() {
       }
     },
     [
-      effectiveFlowId,
-      versions,
       detectEnvVars,
-      setErrorData,
       initConnectionsForFlow,
+      setErrorData,
       updateDetectedEnvVars,
     ],
   );
 
+  const handleAttachFlow = useCallback(
+    async (versionId: string) => {
+      if (!effectiveFlowId) return;
+      const version = versions.find((v) => v.id === versionId);
+      await openConnectionPanelForVersion(
+        effectiveFlowId,
+        versionId,
+        version?.version_tag ?? "",
+      );
+    },
+    [effectiveFlowId, versions, openConnectionPanelForVersion],
+  );
+
+  const handleCreateVersionFromDraft = useCallback(async () => {
+    if (!effectiveFlowId) return;
+
+    try {
+      const snapshot = await createSnapshot({ flowId: effectiveFlowId });
+      await openConnectionPanelForVersion(
+        effectiveFlowId,
+        snapshot.id,
+        snapshot.version_tag,
+      );
+    } catch (err: unknown) {
+      const detail = (err as { response?: { data?: { detail?: string } } })
+        ?.response?.data?.detail;
+      setErrorData({
+        title: "Failed to create version from draft",
+        ...(detail ? { list: [detail] } : {}),
+      });
+    }
+  }, [
+    createSnapshot,
+    effectiveFlowId,
+    openConnectionPanelForVersion,
+    setErrorData,
+  ]);
+
   const handleDetachFlow = useCallback(
     (flowId: string) => {
       handleRemoveAttachedFlow(flowId);
@@ -281,8 +315,10 @@ export default function StepAttachFlows() {
               selectedFlow={selectedFlow}
               versions={versions}
               isLoadingVersions={isLoadingVersions}
+              isCreatingDraftVersion={isCreatingDraftVersion}
               selectedVersionByFlow={selectedVersionByFlow}
               onAttach={handleAttachFlow}
+              onCreateFromDraft={handleCreateVersionFromDraft}
             />
           ) : (
             <ConnectionPanel

src/frontend/src/pages/MainPage/pages/deploymentsPage/components/step-type.tsx

@@ -123,6 +123,7 @@ export default function StepType() {
     !isEditMode &&
     !!providerId &&
     !!trimmedDeploymentName &&
+    !hasDeploymentNameFormatError &&
     !hasAgentNameErrors &&
     !isAgentNameValidationPending;