worker: include condition identifier in conditionUpdate payload

metal-toolbox · May 12, 2023 · c8eb3c2 · c8eb3c2
1 parent a90bb26
commit c8eb3c2
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/internal/worker/worker.go b/internal/worker/worker.go
@@ -444,6 +444,7 @@ func (e *statusEmitter) Publish(ctx context.Context, task *model.Task) {
 	update := &cpv1types.ConditionUpdateEvent{
 		Kind: cptypes.FirmwareInstallOutofband,
 		ConditionUpdate: cpv1types.ConditionUpdate{
+			ID:     task.ID,
 			State:  cptypes.ConditionState(task.State()),
 			Status: statusInfoJSON(task.Status),
 		},