@ -79,7 +79,7 @@ func (ms *mongoStorage) NextJob(namespace string, fn storage.SelectNextJob) (*jw
}
job, err := fn(jr, jtr)
if err != nil {
if job == nil || err != nil {
return nil, err