@@ -224,7 +224,7 @@ func (jm *JobManager) createJobFunction(jc config.JobConfig) func(ctx context.Co
224224 jobLogger .CWarnw (jm .ctx , "Job failed" , "error" , err .Error ())
225225 return err
226226 }
227- jobLogger .CInfow (jm .ctx , "Job succeeded" , "response" , response )
227+ jobLogger .CDebugw (jm .ctx , "Job succeeded" , "response" , response )
228228 return nil
229229 }
230230
@@ -264,7 +264,8 @@ func (jm *JobManager) createJobFunction(jc config.JobConfig) func(ctx context.Co
264264 Formatter : formatter ,
265265 VerbosityLevel : 0 ,
266266 }
267- jobLogger .CInfo (jm .ctx , "Job triggered" )
267+ // Job added for scheduling; may not immediately run.
268+ jobLogger .CDebug (jm .ctx , "Job added" )
268269 grpcMethodCombined := grpcService + "." + grpcMethod
269270 err = grpcurl .InvokeRPC (jm .ctx , descSource , jm .conn , grpcMethodCombined , nil , h , rf .Next )
270271 if err != nil {
@@ -280,7 +281,7 @@ func (jm *JobManager) createJobFunction(jc config.JobConfig) func(ctx context.Co
280281 jobLogger .CWarnw (jm .ctx , "Unmarshalling grpc response failed with error" , "error" , err .Error ())
281282 return err
282283 }
283- jobLogger .CInfow (jm .ctx , "Job succeeded" , "response" , response )
284+ jobLogger .CDebugw (jm .ctx , "Job succeeded" , "response" , response )
284285 return nil
285286 }
286287}
0 commit comments