langflow-ai
diff --git a/‎.secrets.baseline‎
Lines changed: 3 additions & 3 deletions b/‎.secrets.baseline‎
Lines changed: 3 additions & 3 deletions
diff --git a/‎src/backend/base/langflow/api/build.py‎
Lines changed: 12 additions & 9 deletions b/‎src/backend/base/langflow/api/build.py‎
Lines changed: 12 additions & 9 deletions
diff --git a/‎src/backend/base/langflow/api/utils/core.py‎
Lines changed: 3 additions & 3 deletions b/‎src/backend/base/langflow/api/utils/core.py‎
Lines changed: 3 additions & 3 deletions
diff --git a/‎src/backend/base/langflow/api/v1/chat.py‎
Lines changed: 0 additions & 7 deletions b/‎src/backend/base/langflow/api/v1/chat.py‎
Lines changed: 0 additions & 7 deletions
diff --git a/‎src/backend/base/langflow/schema/properties.py‎
Lines changed: 1 addition & 0 deletions b/‎src/backend/base/langflow/schema/properties.py‎
Lines changed: 1 addition & 0 deletions
diff --git a/‎src/backend/tests/unit/components/inputs/test_input_components.py‎
Lines changed: 1 addition & 0 deletions b/‎src/backend/tests/unit/components/inputs/test_input_components.py‎
Lines changed: 1 addition & 0 deletions
diff --git a/‎src/backend/tests/unit/test_build_timer.py‎
Lines changed: 65 additions & 0 deletions b/‎src/backend/tests/unit/test_build_timer.py‎
Lines changed: 65 additions & 0 deletions
diff --git a/‎src/frontend/package-lock.json‎
Lines changed: 11 additions & 0 deletions b/‎src/frontend/package-lock.json‎
Lines changed: 11 additions & 0 deletions
diff --git a/‎src/frontend/package.json‎
Lines changed: 1 addition & 0 deletions b/‎src/frontend/package.json‎
Lines changed: 1 addition & 0 deletions
@@ -1453,23 +1453,23 @@
         "filename": "src/frontend/src/constants/constants.ts",
         "hashed_secret": "19a2fbd0dd38b4097f419c962342ef5e109eab07",
         "is_verified": false,
-        "line_number": 755,
+        "line_number": 763,
         "is_secret": false
       },
       {
         "type": "Secret Keyword",
         "filename": "src/frontend/src/constants/constants.ts",
         "hashed_secret": "3806954324550e26ef5de85d007f1746825a073c",
         "is_verified": false,
-        "line_number": 756,
+        "line_number": 764,
         "is_secret": false
       },
       {
         "type": "Secret Keyword",
         "filename": "src/frontend/src/constants/constants.ts",
         "hashed_secret": "c04f8fbf55c9096907a982750b1c6b0e4c1dd658",
         "is_verified": false,
-        "line_number": 930,
+        "line_number": 939,
         "is_secret": false
       }
     ],
 
@@ -373,13 +373,6 @@ async def _build_vertex(vertex_id: str, graph: Graph, event_manager: EventManage
 
             timedelta = time.perf_counter() - start_time
 
-            # Use client_request_time if available for accurate end-to-end duration
-            if inputs and inputs.client_request_time:
-                # Convert client timestamp (ms) to seconds and calculate elapsed time
-                client_start_seconds = inputs.client_request_time / 1000
-                current_time_seconds = time.time()
-                timedelta = current_time_seconds - client_start_seconds
-
             duration = format_elapsed_time(timedelta)
             result_data_response.duration = duration
             result_data_response.timedelta = timedelta
@@ -454,20 +447,26 @@ async def build_vertices(
         vertex_id: str,
         graph: Graph,
         event_manager: EventManager,
+        vertex_timedeltas: list[float],
     ) -> None:
         """Build vertices and handle their events.
 
         Args:
             vertex_id: The ID of the vertex to build
             graph: The graph instance
             event_manager: Manager for handling events
+            vertex_timedeltas: Shared list to accumulate each vertex's timedelta
         """
         try:
             vertex_build_response: VertexBuildResponse = await _build_vertex(vertex_id, graph, event_manager)
         except asyncio.CancelledError as exc:
             await logger.ainfo(f"Build cancelled: {exc}")
             raise
 
+        # Accumulate the vertex timedelta
+        if vertex_build_response.data.timedelta is not None:
+            vertex_timedeltas.append(vertex_build_response.data.timedelta)
+
         # send built event or error event
         try:
             vertex_build_response_json = vertex_build_response.model_dump_json()
@@ -486,6 +485,7 @@ async def build_vertices(
                         next_vertex_id,
                         graph,
                         event_manager,
+                        vertex_timedeltas,
                     )
                 )
                 tasks.append(task)
@@ -503,9 +503,11 @@ async def build_vertices(
 
     event_manager.on_vertices_sorted(data={"ids": ids, "to_run": vertices_to_run})
 
+    vertex_timedeltas: list[float] = []
+    event_manager.on_build_start(data={})
     tasks = []
     for vertex_id in ids:
-        task = asyncio.create_task(build_vertices(vertex_id, graph, event_manager))
+        task = asyncio.create_task(build_vertices(vertex_id, graph, event_manager, vertex_timedeltas))
         tasks.append(task)
     try:
         await asyncio.gather(*tasks)
@@ -525,7 +527,8 @@ async def build_vertices(
         event_manager.on_error(data=error_message.data)
         raise
 
-    event_manager.on_end(data={})
+    build_duration = sum(vertex_timedeltas)
+    event_manager.on_end(data={"build_duration": build_duration})
     await graph.end_all_traces()
     await event_manager.queue.put((None, None, time.time()))
 
 
@@ -150,7 +150,7 @@ def format_elapsed_time(elapsed_time: float) -> str:
     """Format elapsed time to a human-readable format coming from perf_counter().
 
     - Less than 1 second: returns milliseconds
-    - Less than 1 minute: returns seconds rounded to 2 decimals
+    - Less than 1 minute: returns seconds rounded to 1 decimal
     - 1 minute or more: returns minutes and seconds
     """
     delta = timedelta(seconds=elapsed_time)
@@ -159,12 +159,12 @@ def format_elapsed_time(elapsed_time: float) -> str:
         return f"{milliseconds} ms"
 
     if delta < timedelta(minutes=1):
-        seconds = round(elapsed_time, 2)
+        seconds = round(elapsed_time, 1)
         unit = "second" if seconds == 1 else "seconds"
         return f"{seconds} {unit}"
 
     minutes = delta // timedelta(minutes=1)
-    seconds = round((delta - timedelta(minutes=minutes)).total_seconds(), 2)
+    seconds = round((delta - timedelta(minutes=minutes)).total_seconds(), 1)
     minutes_unit = "minute" if minutes == 1 else "minutes"
     seconds_unit = "second" if seconds == 1 else "seconds"
     return f"{minutes} {minutes_unit}, {seconds} {seconds_unit}"
 
@@ -368,13 +368,6 @@ async def build_vertex(
 
         timedelta = time.perf_counter() - start_time
 
-        # Use client_request_time if available for accurate end-to-end duration
-        if inputs and inputs.client_request_time:
-            # Convert client timestamp (ms) to seconds and calculate elapsed time
-            client_start_seconds = inputs.client_request_time / 1000
-            current_time_seconds = time.time()
-            timedelta = current_time_seconds - client_start_seconds
-
         duration = format_elapsed_time(timedelta)
         result_data_response.duration = duration
         result_data_response.timedelta = timedelta
 
@@ -22,6 +22,7 @@ class Properties(BaseModel):
     positive_feedback: bool | None = None
     state: Literal["partial", "complete"] = "complete"
     targets: list = []
+    build_duration: float | None = None
 
     @field_validator("source", mode="before")
     @classmethod
 
@@ -53,6 +53,7 @@ async def test_message_response(self, component_class, default_kwargs):
             "allow_markdown": False,
             "state": "complete",
             "targets": [],
+            "build_duration": None,
         }
 
     async def test_message_response_ai_sender(self, component_class):
 
@@ -321,3 +321,68 @@ async def test_async_build_without_client_timestamp(self):
         # Should use perf_counter
         if not (inputs and inputs.client_request_time):
             assert 0.09 < duration < 0.15
+
+
+class TestVertexDurationUsesOwnPerfCounter:
+    """Vertex duration must always reflect its own execution time via perf_counter.
+
+    client_request_time must NOT override individual vertex timings because that
+    would make sequential vertices (e.g. Agent → Chat Output) report the same
+    cumulative wall-clock time instead of their own execution duration.
+    """
+
+    def test_should_use_perf_counter_when_client_request_time_is_set(self):
+        """Even when client_request_time exists, vertex duration must come from perf_counter."""
+        # Arrange — client sent request 500ms ago
+        client_start_ms = int((time.time() - 0.5) * 1000)
+        inputs = InputValueRequest(input_value="test", client_request_time=client_start_ms)
+
+        # Act — simulate vertex build taking ~50ms
+        start_time = time.perf_counter()
+        time.sleep(0.05)
+        timedelta = time.perf_counter() - start_time
+        # No client_request_time override — this is the new behavior
+
+        # Assert — duration reflects only the vertex's own execution, not cumulative wall-clock
+        assert inputs.client_request_time is not None, "Precondition: client_request_time is set"
+        assert 0.04 < timedelta < 0.1, f"Expected ~50ms (own execution), got {timedelta}s"
+
+    def test_should_not_show_same_duration_for_sequential_vertices(self):
+        """Two sequential vertices must report different durations reflecting their own work."""
+        # Act — first vertex (slow: ~100ms)
+        start_1 = time.perf_counter()
+        time.sleep(0.1)
+        duration_1 = time.perf_counter() - start_1
+
+        # Act — second vertex (fast: ~20ms)
+        start_2 = time.perf_counter()
+        time.sleep(0.02)
+        duration_2 = time.perf_counter() - start_2
+
+        # Assert — each vertex reports its own execution time
+        assert 0.08 < duration_1 < 0.15, f"First vertex expected ~100ms, got {duration_1}s"
+        assert 0.01 < duration_2 < 0.05, f"Second vertex expected ~20ms, got {duration_2}s"
+        assert duration_1 > duration_2 * 2, "Slow vertex must be significantly longer than fast vertex"
+
+    def test_should_measure_only_vertex_execution_not_cumulative_time(self):
+        """Vertex duration must exclude time spent in prior vertices."""
+        # Arrange — simulate a pipeline: Vertex A (100ms) → Vertex B (20ms)
+        pipeline_start = time.time()
+
+        # Vertex A
+        start_a = time.perf_counter()
+        time.sleep(0.1)
+        duration_a = time.perf_counter() - start_a
+
+        # Vertex B
+        start_b = time.perf_counter()
+        time.sleep(0.02)
+        duration_b = time.perf_counter() - start_b
+
+        cumulative = time.time() - pipeline_start
+
+        # Assert
+        assert duration_b < cumulative / 2, (
+            f"Vertex B ({duration_b}s) must be much less than cumulative ({cumulative}s)"
+        )
+        assert duration_b < duration_a, "Fast vertex B must be shorter than slow vertex A"
@@ -148,6 +148,7 @@
     "@storybook/react-vite": "^10.1.0",
     "@swc/cli": "^0.5.2",
     "@swc/core": "^1.6.1",
+    "@tailwindcss/container-queries": "^0.1.1",
     "@tailwindcss/typography": "^0.5.13",
     "@testing-library/dom": "^10.4.1",
     "@testing-library/jest-dom": "^6.9.1",
Original file line number	Diff line number	Diff line change
`@@ -53,6 +53,7 @@ async def test_message_response(self, component_class, default_kwargs):`
`53`	`53`	`"allow_markdown": False,`
`54`	`54`	`"state": "complete",`
`55`	`55`	`"targets": [],`
	`56`	`+ "build_duration": None,`
`56`	`57`	`}`
`57`	`58`
`58`	`59`	`async def test_message_response_ai_sender(self, component_class):`