feat: add execution_id and task_id to the replication webhook payload (#21614)

Signed-off-by: chlins <chlins.zhang@gmail.com>
This commit is contained in:
Chlins Zhang 2025-02-11 14:58:07 +08:00 committed by GitHub
parent fee92c5189
commit 490f898aec
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 4 additions and 0 deletions

View File

@ -163,6 +163,8 @@ func constructReplicationPayload(ctx context.Context, event *event.ReplicationEv
OverrideMode: rpPolicy.Override,
TriggerType: string(execution.Trigger),
ExecutionTimestamp: execution.StartTime.Unix(),
ExecutionID: execution.ID,
TaskID: task.ID,
},
},
}

View File

@ -36,6 +36,8 @@ type Replication struct {
DestResource *ReplicationResource `json:"dest_resource,omitempty"`
SuccessfulArtifact []*ArtifactInfo `json:"successful_artifact,omitempty"`
FailedArtifact []*ArtifactInfo `json:"failed_artifact,omitempty"`
ExecutionID int64 `json:"execution_id,omitempty"`
TaskID int64 `json:"task_id,omitempty"`
}
// ArtifactInfo describe info of artifact