Add new environment variables and improve logging

Added OWNER, OWNER_NAME, OWNER_EMAIL, and CONNECTOR_TYPE environment variables to docker-compose.yml and updated LANGFLOW_VARIABLES_TO_GET_FROM_ENVIRONMENT accordingly. Modified ingestion_flow.json to adjust node selection and className, and cleared a sensitive value. Added logging for metadata tweaks in langflow_file_service.py for better traceability.

docker-compose.yml

@@ -103,9 +103,13 @@ services:
       - LANGFLOW_LOAD_FLOWS_PATH=/app/flows
       - LANGFLOW_SECRET_KEY=${LANGFLOW_SECRET_KEY}
       - JWT="dummy"
+      - OWNER="dummy"
+      - OWNER_NAME="dummy"
+      - OWNER_EMAIL="dummy"
+      - CONNECTOR_TYPE="dummy"
       - OPENRAG-QUERY-FILTER="{}"
       - OPENSEARCH_PASSWORD=${OPENSEARCH_PASSWORD}
-      - LANGFLOW_VARIABLES_TO_GET_FROM_ENVIRONMENT=JWT,OPENRAG-QUERY-FILTER,OPENSEARCH_PASSWORD
+      - LANGFLOW_VARIABLES_TO_GET_FROM_ENVIRONMENT=JWT,OPENRAG-QUERY-FILTER,OPENSEARCH_PASSWORD,OWNER,OWNER_NAME,OWNER_EMAIL,CONNECTOR_TYPE
       - LANGFLOW_LOG_LEVEL=DEBUG
       - LANGFLOW_AUTO_LOGIN=${LANGFLOW_AUTO_LOGIN}
       - LANGFLOW_SUPERUSER=${LANGFLOW_SUPERUSER}

flows/ingestion_flow.json

@@ -206,7 +206,7 @@
       },
       {
         "animated": false,
-        "className": "",
+        "className": "not-running",
         "data": {
           "sourceHandle": {
             "dataType": "AdvancedDynamicFormBuilder",
@@ -1339,7 +1339,7 @@
                 "show": true,
                 "title_case": false,
                 "type": "str",
-                "value": "eyJhbGciOiJSUzI1NiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJodHRwOi8vb3BlbnJhZy1iYWNrZW5kOjgwMDAiLCJzdWIiOiIxMDUzNTI0NjY1OTg1Mjg4ODA1NjAiLCJhdWQiOlsib3BlbnNlYXJjaCIsIm9wZW5yYWciXSwiZXhwIjoxNzU5NDY3NDIzLCJpYXQiOjE3NTg4NjI2MjMsImF1dGhfdGltZSI6MTc1ODg3NzAyMywidXNlcl9pZCI6IjEwNTM1MjQ2NjU5ODUyODg4MDU2MCIsImVtYWlsIjoiZWR3aW4uam9zZUBkYXRhc3RheC5jb20iLCJuYW1lIjoiRWR3aW4gSm9zZSIsInByZWZlcnJlZF91c2VybmFtZSI6ImVkd2luLmpvc2VAZGF0YXN0YXguY29tIiwiZW1haWxfdmVyaWZpZWQiOnRydWUsInJvbGVzIjpbIm9wZW5yYWdfdXNlciJdfQ.Xxi2c7lOseXAMPx7UvfBS-GBrcThfWXnBfoVbxbzt5wLpvmE0Gg5Mzc_qZ2e2LJIL5QsK-Q_W4pArxDLx8nh-ICNdfABkHFvekmW7CgJA70orkJ-bUUyxmjtd5obPFwtCiu2EQEgU2MyEm8BNiI3dd2DQIDSb0ArCaxglr42l9rsAEQ-MyZWz4H5m2Ijs0anguPfyPSTFG6_Qdr7U7uCB2XjsIo0Um88ofH0C0ERGzvK0CrbvX9Ubvde3IHSKlmblw3ZTRIN_UKMfwzOIQp65dWbxMo4H0bV51jtNpnCYombDinAYGAM3UPYrx2ny0Mlih0mwcSOyYHj5kPP3NDW7A"
+                "value": ""
               },
               "m": {
                 "_input_type": "IntInput",
@@ -2206,7 +2206,7 @@
           "x": 1363.7188885586695,
           "y": 1810.433145275832
         },
-        "selected": false,
+        "selected": true,
         "type": "genericNode"
       },
       {
@@ -2406,7 +2406,7 @@
           "x": 714.4587372144712,
           "y": 2004.1002386954729
         },
-        "selected": true,
+        "selected": false,
         "type": "genericNode"
       },
       {

src/services/langflow_file_service.py

@@ -106,7 +106,7 @@ class LangflowFileService:
             metadata_tweaks.append({"key": "owner_email", "value": owner_email})
         if connector_type:
             metadata_tweaks.append({"key": "connector_type", "value": connector_type})
-
+        logger.info(f"[LF] Metadata tweaks {metadata_tweaks}")
         # if metadata_tweaks:
         #     # Initialize the OpenSearch component tweaks if not already present
         #     if "OpenSearchHybrid-Ve6bS" not in tweaks: