File tree 1 file changed +9
-0
lines changed
1 file changed +9
-0
lines changed Original file line number Diff line number Diff line change @@ -86,6 +86,7 @@ int Job::Execute()
86
86
87
87
if (!steps)
88
88
{
89
+ LogMessage (" No steps found for jobid " + m_jobid, LOG_WARNING);
89
90
m_status = " i" ;
90
91
return -1 ;
91
92
}
@@ -110,13 +111,17 @@ int Job::Execute()
110
111
" FROM pgagent.pga_jobstep WHERE jstid=" + stepid);
111
112
112
113
if (res)
114
+ {
113
115
rc = res->RowsAffected ();
116
+ LogMessage (" Number of rows affected for jobid " + m_jobid, LOG_DEBUG);
117
+ }
114
118
else
115
119
rc = -1 ;
116
120
}
117
121
118
122
if (rc != 1 )
119
123
{
124
+ LogMessage (" Value of rc is " + std::to_string (rc) + " for job " + m_jobid, LOG_WARNING);
120
125
m_status = " i" ;
121
126
return -1 ;
122
127
}
@@ -380,6 +385,7 @@ int Job::Execute()
380
385
default :
381
386
{
382
387
output = " Invalid step type!" ;
388
+ LogMessage (" Invalid step type!" , LOG_WARNING);
383
389
m_status = " i" ;
384
390
return -1 ;
385
391
}
@@ -437,6 +443,9 @@ void JobThread::operator()()
437
443
}
438
444
else
439
445
{
446
+ LogMessage (" Failed to launch the thread for job " + m_jobid +
447
+ " . Inserting an entry to the joblog table with status 'i'" , LOG_WARNING);
448
+
440
449
// Failed to launch the thread. Insert an entry with
441
450
// "internal error" status in the joblog table, to leave
442
451
// a trace of fact that we tried to launch the job.
You can’t perform that action at this time.
0 commit comments