diff --git a/core/services/workflows/engine.go b/core/services/workflows/engine.go index e20af85540d..0b84b65d199 100644 --- a/core/services/workflows/engine.go +++ b/core/services/workflows/engine.go @@ -283,6 +283,7 @@ func (e *Engine) initializeCapability(ctx context.Context, step *step) error { Metadata: capabilities.RegistrationMetadata{ WorkflowID: e.workflow.id, WorkflowOwner: e.workflow.owner, + ReferenceID: step.Vertex.Ref, }, Config: stepConfig, } @@ -1100,6 +1101,7 @@ func (e *Engine) Close() error { Metadata: capabilities.RegistrationMetadata{ WorkflowID: e.workflow.id, WorkflowOwner: e.workflow.owner, + ReferenceID: s.Vertex.Ref, }, Config: stepConfig, }