Merge pull request #200 from langflow-ai/add-mcp-agent-flows

feat: Update openrag_agent.json to add MCP support

Dockerfile.langflow

@@ -1,4 +1,4 @@
-FROM langflowai/langflow-nightly:1.6.3.dev0
+FROM langflowai/langflow-nightly:1.6.3.dev1
 
 EXPOSE 7860
 

docker-compose-cpu.yml

@@ -108,6 +108,7 @@ services:
       - OWNER_NAME=None
       - OWNER_EMAIL=None
       - CONNECTOR_TYPE=system
+      - CONNECTOR_TYPE_URL=url
       - OPENRAG-QUERY-FILTER="{}"
       - OPENSEARCH_PASSWORD=${OPENSEARCH_PASSWORD}
       - FILENAME=None

docker-compose.yml

@@ -81,7 +81,6 @@ services:
     # build:
     #   context: .
     #   dockerfile: Dockerfile.frontend
-      #dockerfile: Dockerfile.frontend
     container_name: openrag-frontend
     depends_on:
       - openrag-backend
@@ -109,6 +108,7 @@ services:
       - OWNER_NAME=None
       - OWNER_EMAIL=None
       - CONNECTOR_TYPE=system
+      - CONNECTOR_TYPE_URL=url
       - OPENRAG-QUERY-FILTER="{}"
       - FILENAME=None
       - MIMETYPE=None

flows/openrag_url_mcp.json

@@ -232,6 +232,7 @@
       },
       {
         "animated": false,
+        "className": "",
         "data": {
           "sourceHandle": {
             "dataType": "EmbeddingModel",
@@ -733,6 +734,10 @@
                   {
                     "key": "owner_email",
                     "value": "OWNER_EMAIL"
+                  },
+                  {
+                    "key": "connector_type",
+                    "value": "CONNECTOR_TYPE_URL"
                   }
                 ]
               },
@@ -1808,7 +1813,7 @@
             ],
             "frozen": false,
             "icon": "table",
-            "last_updated": "2025-10-03T20:31:36.023Z",
+            "last_updated": "2025-10-06T17:46:55.068Z",
             "legacy": false,
             "lf_version": "1.6.0",
             "metadata": {
@@ -2224,7 +2229,7 @@
             ],
             "frozen": false,
             "icon": "table",
-            "last_updated": "2025-10-03T20:31:36.025Z",
+            "last_updated": "2025-10-06T17:46:55.069Z",
             "legacy": false,
             "lf_version": "1.6.0",
             "metadata": {
@@ -2897,7 +2902,7 @@
             ],
             "frozen": false,
             "icon": "table",
-            "last_updated": "2025-10-03T20:31:36.026Z",
+            "last_updated": "2025-10-06T17:46:55.069Z",
             "legacy": false,
             "metadata": {
               "code_hash": "b4d6b19b6eef",
@@ -3310,7 +3315,7 @@
             ],
             "frozen": false,
             "icon": "binary",
-            "last_updated": "2025-10-03T20:31:47.177Z",
+            "last_updated": "2025-10-06T17:46:54.996Z",
             "legacy": false,
             "metadata": {
               "code_hash": "8607e963fdef",
@@ -3595,17 +3600,17 @@
       }
     ],
     "viewport": {
-      "x": -407.1633937626607,
-      "y": -577.5291936220412,
-      "zoom": 0.5347553210574026
+      "x": -538.2311610019549,
+      "y": -337.3313239657308,
+      "zoom": 0.45546556043892106
     }
   },
   "description": "This flow is to ingest the URL to open search.",
   "endpoint_name": null,
-  "mcp_enabled": true,
   "id": "72c3d17c-2dac-4a73-b48a-6518473d7830",
+  "mcp_enabled": true,
   "is_component": false,
-  "last_tested_version": "1.6.0",
+  "last_tested_version": "1.6.3.dev1",
   "name": "OpenSearch URL Ingestion Flow",
   "tags": [
     "openai",

src/services/auth_service.py

@@ -296,11 +296,16 @@ class AuthService:
             try:
                 if self.langflow_mcp_service and isinstance(jwt_token, str) and jwt_token.strip():
                     global_vars = {"JWT": jwt_token}
+                    global_vars["CONNECTOR_TYPE_URL"] = "url"
                     if user_info:
                         if user_info.get("id"):
                             global_vars["OWNER"] = user_info.get("id")
                         if user_info.get("name"):
-                            global_vars["OWNER_NAME"] = user_info.get("name")
+                            # OWNER_NAME may contain spaces, which can cause issues in headers.
+                            # Alternative: URL-encode the owner name to preserve spaces and special characters.
+                            owner_name = user_info.get("name")
+                            if owner_name:
+                                global_vars["OWNER_NAME"] = str(f"\"{owner_name}\"")
                         if user_info.get("email"):
                             global_vars["OWNER_EMAIL"] = user_info.get("email")
 

src/tui/_assets/docker-compose-cpu.yml

@@ -105,6 +105,7 @@ services:
       - OWNER_NAME=None
       - OWNER_EMAIL=None
       - CONNECTOR_TYPE=system
+      - CONNECTOR_TYPE_URL=url
       - OPENRAG-QUERY-FILTER="{}"
       - OPENSEARCH_PASSWORD=${OPENSEARCH_PASSWORD}
       - FILENAME=None

src/tui/_assets/docker-compose.yml

@@ -105,6 +105,7 @@ services:
       - OWNER_NAME=None
       - OWNER_EMAIL=None
       - CONNECTOR_TYPE=system
+      - CONNECTOR_TYPE_URL=url
       - OPENRAG-QUERY-FILTER="{}"
       - OPENSEARCH_PASSWORD=${OPENSEARCH_PASSWORD}
       - FILENAME=None