SubgraphExecutionCompletedEvent

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

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

Constructors

constructor(runId: String, subgraphName: String, input: JsonElement?, output: JsonElement?, timestamp: Long = Clock.System.now().toEpochMilliseconds())

The input data provided to the subgraph;

Specifies the type of the feature message for this event.

The output data generated by the subgraph;

Unique identifier for the subgraph run;

The name of the subgraph being executed;

open override val timestamp: Long

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