Skip to content

N
node-bigstream
Commit 018199a3 authored by Kamron Aroonrua's avatar Kamron Aroonrua 💬
Browse files
Options

jobtask

parent 152f6d53
Show whitespace changes
Inline Side-by-side
Showing with 3 additions and 1 deletion
jobworker/lib/jobtask.js
View file @ 018199a3
......@@ -213,13 +213,15 @@ JobTask.prototype.run = function ()
async.waterfall([task_di,task_dt,task_do],function (err,resp) {
clearTimeout(jtimeout);
console.log('[JOB DONE] id=' + job_id + ' ,tr=' + transaction_id + '\t' + resp.status);
//console.log('[JOB DONE] id=' + job_id + ' ,tr=' + transaction_id + '\t' + resp.status);
if(!err){
self.stop(resp)
// console.log('***** JOB SUCCESSFULLY DONE *****\n');
console.log('[JOB DONE] id=' + job_id + ' ,tr=' + transaction_id + '\tsuccess');
}else{
self.stop(err)
// console.log('***** JOB UNSUCCESSFULLY DONE *****\n');
console.log('[JOB DONE] id=' + job_id + ' ,tr=' + transaction_id + '\tunsuccess');
}
});
......
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