diff --git a/pkg/operator/resources/batchapi/manage_resources_cron.go b/pkg/operator/resources/batchapi/manage_resources_cron.go index 3747e2f15e..4beb6c3a63 100644 --- a/pkg/operator/resources/batchapi/manage_resources_cron.go +++ b/pkg/operator/resources/batchapi/manage_resources_cron.go @@ -116,7 +116,6 @@ func ManageJobResources() error { errors.PrintError(err) continue } - if newStatusCode != jobState.Status { err = errors.FirstError( writeToJobLogStream(jobKey, msg), @@ -128,6 +127,10 @@ func ManageJobResources() error { continue } } + if queueURL == nil { + // job has been submitted within the grace period, it may take a while for a newly created queue to be listed in SQS api response + continue + } err = checkIfJobCompleted(jobKey, *queueURL, k8sJob) if err != nil {