Commit df5ceb94 authored by Alessio Netti's avatar Alessio Netti
Browse files

collectagent: added ID to job data insertion error messages

parent 89ebfe7b
......@@ -458,19 +458,19 @@ int mqttCallback(SimpleMQTTMessage *msg)
if ((jd.endTime == DCDB::TimeStamp((uint64_t)0)) || ((jd.endTime.getRaw() & 0x1) == 1)) {
//starting job data
if (myJobDataStore->insertJob(jd) != DCDB::JD_OK) {
LOG(error) << "Job data insert failed!";
LOG(error) << "Job data insert for job " << jd.jobId << " failed!";
return 1;
}
} else {
//ending job data
DCDB::JobData tmp;
if (myJobDataStore->getJobById(tmp, jd.jobId, jd.domainId) != DCDB::JD_OK) {
LOG(error) << "Could not retrieve job to be updated!";
LOG(error) << "Could not retrieve job " << jd.jobId << " to be updated!";
return 1;
}
if (myJobDataStore->updateEndtime(tmp.jobId, tmp.startTime, jd.endTime, jd.domainId) != DCDB::JD_OK) {
LOG(error) << "Could not update end time of job!";
LOG(error) << "Could not update end time of job " << tmp.jobId << "!";
return 1;
}
}
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment