File tree 1 file changed +2
-2
lines changed
1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -135,7 +135,7 @@ func (handler *SQSHandler) StartMonitoringProcess() {
135
135
k8sJob , err := GetJobStatusByID (jobInfo .UID )
136
136
if err != nil {
137
137
glog .Errorf ("Can not get k8s job %s. Detail %s. Resend the message to the queue" , jobInfo .Name , err )
138
- handler .ResendSQSMessage (handler .QueueURL , k8sJob .SQSMessage )
138
+ handler .ResendSQSMessage (handler .QueueURL , jobInfo .SQSMessage )
139
139
} else {
140
140
glog .Infof ("%s: %s" , k8sJob .Name , k8sJob .Status )
141
141
if k8sJob .Status == "Unknown" || k8sJob .Status == "Running" {
@@ -278,13 +278,13 @@ func (handler *SQSHandler) HandleSQSMessage(message *sqs.Message) error {
278
278
glog .Errorln (err )
279
279
return err
280
280
}
281
+ jobInfo .SQSMessage = message
281
282
out , err := json .Marshal (jobInfo )
282
283
if err != nil {
283
284
glog .Infof ("Error :%s" , err )
284
285
glog .Errorln (err )
285
286
return err
286
287
}
287
- jobInfo .SQSMessage = message
288
288
glog .Info (string (out ))
289
289
handler .Mu .Lock ()
290
290
handler .MonitoredJobs = append (handler .MonitoredJobs , jobInfo )
You can’t perform that action at this time.
0 commit comments