Add execution durations to flow

app/graphql/types/flow_type.rb

@@ -11,6 +11,9 @@ class FlowType < Types::BaseObject
     field :input_type, Types::DataTypeType,
           null: true,
           description: 'The input data type of the flow'
+    field :last_execution_duration, Integer,
+          null: true,
+          description: 'The duration of the last execution of the flow in nanoseconds'
     field :return_type, Types::DataTypeType,
           null: true,
           description: 'The return data type of the flow'

app/grpc/runtime_usage_handler.rb

@@ -0,0 +1,27 @@
+# frozen_string_literal: true
+
+class RuntimeUsageHandler < Tucana::Sagittarius::RuntimeUsageService::Service
+  include GrpcHandler
+  include Code0::ZeroTrack::Loggable
+
+  def update(request, _call)
+    current_runtime = Runtime.find(Code0::ZeroTrack::Context.current[:runtime][:id])
+
+    request.runtime_usage.each do |usage_info|
+      flow = Flow.find_by(id: usage_info.flow_id)
+
+      if flow.nil? || flow.project.primary_runtime != current_runtime
+        logger.error(
+          message: 'Flow not found or does not belong to current runtime',
+          runtime_id: current_runtime.id,
+          flow_id: usage_info.flow_id
+        )
+        return Tucana::Sagittarius::RuntimeUsageResponse.new(success: false)
+      end
+      flow.last_execution_duration = usage_info.duration.to_i
+      flow.save!
+    end
+
+    Tucana::Sagittarius::RuntimeUsageeResponse.new(success: true)
+  end
+end

db/migrate/20251217140333_add_last_execution_duration_to_flows.rb

@@ -0,0 +1,7 @@
+# frozen_string_literal: true
+
+class AddLastExecutionDurationToFlows < Code0::ZeroTrack::Database::Migration[1.0]
+  def change
+    add_column :flows, :last_execution_duration, :bigint, null: true, default: nil
+  end
+end

db/schema_migrations/20251217140333

@@ -0,0 +1 @@
+bc5cbc74c587f21ba1d98a76876dfd3d5e91bc2e4ef2eccd8d85129f5f740fb3

db/structure.sql

@@ -252,7 +252,8 @@ CREATE TABLE flows (
     starting_node_id bigint,
     name text NOT NULL,
     created_at timestamp with time zone NOT NULL,
-    updated_at timestamp with time zone NOT NULL
+    updated_at timestamp with time zone NOT NULL,
+    last_execution_duration bigint
 );
 
 CREATE SEQUENCE flows_id_seq

docs/graphql/object/flow.md

@@ -11,6 +11,7 @@ Represents a flow
 | `createdAt` | [`Time!`](../scalar/time.md) | Time when this Flow was created |
 | `id` | [`FlowID!`](../scalar/flowid.md) | Global ID of this Flow |
 | `inputType` | [`DataType`](../object/datatype.md) | The input data type of the flow |
+| `lastExecutionDuration` | [`Int`](../scalar/int.md) | The duration of the last execution of the flow in nanoseconds |
 | `name` | [`String!`](../scalar/string.md) | Name of the flow |
 | `nodes` | [`NodeFunctionConnection!`](../object/nodefunctionconnection.md) | Nodes of the flow |
 | `returnType` | [`DataType`](../object/datatype.md) | The return data type of the flow |

spec/graphql/types/flow_type_type_spec.rb

@@ -10,6 +10,7 @@
       input_type
       return_type
       flow_type_settings
+      last_execution_duration
       names
       display_messages
       aliases