We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent fe1bdc9 commit a6e14beCopy full SHA for a6e14be
workers/agent/agent.go
@@ -377,7 +377,7 @@ func (a *Agent) scheduleWork() {
377
// Setup reschedule of pipeline in case something goes wrong
378
reschedulePipeline := func() {
379
pipelineRunPB.Status = string(gaia.RunReschedule)
380
- if _, err := a.client.UpdateWork(context.Background(), pipelineRunPB); err != nil {
+ if _, err := a.client.UpdateWork(ctx, pipelineRunPB); err != nil {
381
gaia.Cfg.Logger.Error("failed to reschedule work at primary instance", "error", err)
382
}
383
0 commit comments