feat: detach tool execution outside runtime

Author: 0x3bfc

Dockerfile

@@ -1,7 +1,7 @@
 # syntax=docker/dockerfile:1
 # Dockerfile for Langflow Executor Node
-# Build from repo root: docker build -f node/Dockerfile -t langflow-executor-node .
-# OR build from node directory: docker build -f Dockerfile -t langflow-executor-node ../
+# Build from repo root: docker build -f nodes/langflow-executor-node/Dockerfile -t langflow-executor-node .
+# OR from droqflow directory: cd droqflow && docker build -f ../nodes/langflow-executor-node/Dockerfile -t langflow-executor-node .
 
 ################################
 # BUILDER STAGE
@@ -28,15 +28,15 @@ ENV UV_COMPILE_BYTECODE=1
 ENV UV_LINK_MODE=copy
 
 # Copy Langflow dependency files first (for better caching)
-# These paths work when building from repo root
-COPY app/src/lfx/pyproject.toml /app/src/lfx/pyproject.toml
-COPY app/src/lfx/README.md /app/src/lfx/README.md
+# These paths assume build context includes droqflow directory
+COPY droqflow/app/src/lfx/pyproject.toml /app/src/lfx/pyproject.toml
+COPY droqflow/app/src/lfx/README.md /app/src/lfx/README.md
 
 # Copy executor node dependency files
-COPY node/pyproject.toml /app/node/pyproject.toml
+COPY nodes/langflow-executor-node/pyproject.toml /app/node/pyproject.toml
 
 # Copy Langflow source (needed for installation)
-COPY app/src/lfx/src /app/src/lfx/src
+COPY droqflow/app/src/lfx/src /app/src/lfx/src
 
 # Install Langflow (lfx) package with all dependencies
 # This installs lfx and all its dependencies from pyproject.toml
@@ -47,6 +47,7 @@ RUN --mount=type=cache,target=/root/.cache/uv \
 # Install common Langchain integration packages needed by components
 RUN --mount=type=cache,target=/root/.cache/uv \
     uv pip install --system --no-cache \
+    "langchain-core>=0.3.79,<0.4.0" \
     langchain-anthropic \
     langchain-openai \
     langchain-community \
@@ -69,10 +70,10 @@ RUN --mount=type=cache,target=/root/.cache/uv \
     python-dotenv
 
 # Copy executor node source
-COPY node/src /app/node/src
+COPY nodes/langflow-executor-node/src /app/node/src
 
 # Copy components.json mapping file
-COPY node/components.json /app/components.json
+COPY nodes/langflow-executor-node/components.json /app/components.json
 
 ################################
 # RUNTIME STAGE

components.json

@@ -4,7 +4,6 @@
   "APIRequestComponent": "lfx.components.data.api_request",
   "AddContentToPage": "lfx.components.Notion.add_content_to_page",
   "AgentComponent": "lfx.components.agents.agent",
-  "AgentQL": "lfx.components.agentql.agentql_api",
   "AlterMetadataComponent": "lfx.components.processing.alter_metadata",
   "AmazonBedrockComponent": "lfx.components.amazon.amazon_bedrock_model",
   "AmazonBedrockConverseComponent": "lfx.components.amazon.amazon_bedrock_converse",

lfx/src/lfx/base/tools/component_tool.py

@@ -1,6 +1,8 @@
 from __future__ import annotations
 
 import asyncio
+import copy
+import logging
 import re
 from typing import TYPE_CHECKING, Literal
 
@@ -25,6 +27,8 @@
     from lfx.schema.content_block import ContentBlock
     from lfx.schema.dotdict import dotdict
 
+logger = logging.getLogger(__name__)
+
 TOOL_TYPES_SET = {"Tool", "BaseTool", "StructuredTool"}
 
 
@@ -168,6 +172,54 @@ def _should_skip_output(self, output: Output) -> bool:
             output.name == TOOL_OUTPUT_NAME or any(tool_type in output.types for tool_type in TOOL_TYPES_SET)
         )
 
+    def _attach_runtime_metadata(
+        self,
+        tool: BaseTool | StructuredTool,
+        output: Output,
+        *,
+        is_async: bool,
+        args_schema: type | None,
+    ) -> None:
+        """Annotate tool metadata with component/runtime information."""
+        metadata = tool.metadata or {}
+        metadata["_component_method"] = output.method
+        metadata["_component_is_async"] = is_async
+        metadata["component_class"] = self.component.__class__.__name__
+        metadata["component_module"] = self.component.__class__.__module__
+        metadata["component_id"] = self.component.get_id()
+        metadata["stream_topic"] = self.component._build_stream_topic()  # noqa: SLF001
+
+        try:
+            component_state = self.component._serialize_for_executor()  # noqa: SLF001
+            metadata["_component_state"] = component_state
+        except Exception as exc:  # noqa: BLE001
+            logger.warning(
+                "Failed to serialize component state for tool '%s': %s",
+                tool.name,
+                exc,
+            )
+
+        metadata["_tool_input_keys"] = self._extract_input_keys(args_schema, output)
+
+        executor_meta = self.component.get_executor_node_metadata()
+        if executor_meta:
+            metadata["executor_node"] = executor_meta
+        tool.metadata = metadata
+
+    @staticmethod
+    def _extract_input_keys(args_schema: type | None, output: Output) -> list[str]:
+        """Return list of input field names for this tool."""
+        keys: list[str] = []
+        if args_schema is not None:
+            for attr_name in ("model_fields", "__fields__"):
+                schema_fields = getattr(args_schema, attr_name, None)
+                if schema_fields:
+                    keys = list(schema_fields.keys())
+                    break
+        if not keys and getattr(output, "required_inputs", None):
+            keys = list(output.required_inputs)
+        return keys
+
     def get_tools(
         self,
         tool_name: str | None = None,
@@ -228,37 +280,37 @@ def get_tools(
             formatted_name = _format_tool_name(name)
             event_manager = self.component.get_event_manager()
             if asyncio.iscoroutinefunction(output_method):
-                tools.append(
-                    StructuredTool(
-                        name=formatted_name,
-                        description=build_description(self.component),
-                        coroutine=_build_output_async_function(self.component, output_method, event_manager),
-                        args_schema=args_schema,
-                        handle_tool_error=True,
-                        callbacks=callbacks,
-                        tags=[formatted_name],
-                        metadata={
-                            "display_name": formatted_name,
-                            "display_description": build_description(self.component),
-                        },
-                    )
+                structured_tool = StructuredTool(
+                    name=formatted_name,
+                    description=build_description(self.component),
+                    coroutine=_build_output_async_function(self.component, output_method, event_manager),
+                    args_schema=args_schema,
+                    handle_tool_error=True,
+                    callbacks=callbacks,
+                    tags=[formatted_name],
+                    metadata={
+                        "display_name": formatted_name,
+                        "display_description": build_description(self.component),
+                    },
                 )
+                tools.append(structured_tool)
+                self._attach_runtime_metadata(structured_tool, output, is_async=True, args_schema=args_schema)
             else:
-                tools.append(
-                    StructuredTool(
-                        name=formatted_name,
-                        description=build_description(self.component),
-                        func=_build_output_function(self.component, output_method, event_manager),
-                        args_schema=args_schema,
-                        handle_tool_error=True,
-                        callbacks=callbacks,
-                        tags=[formatted_name],
-                        metadata={
-                            "display_name": formatted_name,
-                            "display_description": build_description(self.component),
-                        },
-                    )
+                structured_tool = StructuredTool(
+                    name=formatted_name,
+                    description=build_description(self.component),
+                    func=_build_output_function(self.component, output_method, event_manager),
+                    args_schema=args_schema,
+                    handle_tool_error=True,
+                    callbacks=callbacks,
+                    tags=[formatted_name],
+                    metadata={
+                        "display_name": formatted_name,
+                        "display_description": build_description(self.component),
+                    },
                 )
+                tools.append(structured_tool)
+                self._attach_runtime_metadata(structured_tool, output, is_async=False, args_schema=args_schema)
         if len(tools) == 1 and (tool_name or tool_description):
             tool = tools[0]
             tool.name = _format_tool_name(str(tool_name)) or tool.name