SubgraphExecutionStartingEvent

data class SubgraphExecutionStartingEvent(val runId: String, val subgraphName: String, val input: JsonElement?, val timestamp: Long = Clock.System.now().toEpochMilliseconds()) : DefinedFeatureEvent(source)

Represents an event triggered when the execution of a specific subgraph starts.

This event captures the initiation of a subgraph execution, including details such as the unique run identifier, the name of the subgraph, and the input data provided to the subgraph.

Constructors

Link copied to clipboard
constructor(runId: String, subgraphName: String, input: JsonElement?, timestamp: Long = Clock.System.now().toEpochMilliseconds())

Properties

Link copied to clipboard

The input data provided to the subgraph;

Link copied to clipboard
open override val messageType: FeatureMessage.Type

Specifies the type of the feature message for this event.

Link copied to clipboard

Unique identifier for the subgraph run;

Link copied to clipboard

The name of the subgraph being executed;

Link copied to clipboard
open override val timestamp: Long

The timestamp of the event, in milliseconds since the Unix epoch.