diff --git a/master/internal/rm/dispatcherrm/dispatcher_monitor.go b/master/internal/rm/dispatcherrm/dispatcher_monitor.go index ad59f9d2c3b5..32486f6783af 100644 --- a/master/internal/rm/dispatcherrm/dispatcher_monitor.go +++ b/master/internal/rm/dispatcherrm/dispatcher_monitor.go @@ -676,16 +676,20 @@ func (m *launcherMonitor) updateJobStatus(ctx *actor.Context, job *launcherJob) // Dispatch was not found. if !ok { + missingDispatchMsg := "The job was canceled" if job.jobWasTerminated { - ctx.Log().WithField("dispatch-id", dispatchID).Infof("The job was canceled") - - ctx.Tell(ctx.Self(), DispatchExited{ - DispatchID: dispatchID, - ExitCode: -1, - Message: "Job was canceled", - }) + ctx.Log().WithField("dispatch-id", dispatchID).Info(missingDispatchMsg) + } else { + missingDispatchMsg = "The job was lost" + ctx.Log().WithField("dispatch-id", dispatchID).Error(missingDispatchMsg) } + ctx.Tell(ctx.Self(), DispatchExited{ + DispatchID: dispatchID, + ExitCode: -1, + Message: missingDispatchMsg, + }) + return true }