Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Submit feedback
Sign in
Toggle navigation
N
node-bigstream
Project
Project
Details
Activity
Releases
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
3
Merge Requests
3
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
bs
node-bigstream
Commits
aae468de
Commit
aae468de
authored
Mar 26, 2020
by
Kamron Aroonrua
💬
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
disable log
parent
3ee9ce3f
Show whitespace changes
Inline
Side-by-side
Showing
1 changed file
with
12 additions
and
12 deletions
+12
-12
jobtask.js
jobworker/lib/jobtask.js
+12
-12
No files found.
jobworker/lib/jobtask.js
View file @
aae468de
...
...
@@ -98,8 +98,8 @@ JobTask.prototype.run = function ()
var
task_di
=
function
(
callback
)
{
var
dm_i
=
domain
.
create
();
dm_i
.
on
(
'error'
,
function
(
err
)
{
console
.
log
(
'[DI] plugins error'
);
console
.
log
(
err
);
//
console.log('[DI] plugins error');
//
console.log(err);
self
.
stats
.
di
=
{
'status'
:
'error'
,
'data'
:
'plugins error'
};
callback
({
'status'
:
'error'
,
'data'
:
'plugins error'
});
});
...
...
@@ -129,8 +129,8 @@ JobTask.prototype.run = function ()
var
dm_t
=
domain
.
create
();
dm_t
.
on
(
'error'
,
function
(
err
)
{
console
.
log
(
'[DT] plugins error'
);
console
.
log
(
err
);
//
console.log('[DT] plugins error');
//
console.log(err);
self
.
stats
.
dt
=
{
'status'
:
'error'
,
'data'
:
'plugins error'
};
callback
({
'status'
:
'error'
,
'data'
:
'plugins error'
});
});
...
...
@@ -149,7 +149,7 @@ JobTask.prototype.run = function ()
perform_dt
({
'cfg'
:
cur_cfg
,
'name'
:
dt_name
,
'context'
:
context
,
'request'
:
dt_request
,
'handle'
:
self
},
function
(
err
,
dt_resp
){
if
(
dt_resp
){
console
.
log
(
'[DT:'
+
dt_name
+
' STATUS]
\
t
\
t: '
+
dt_resp
.
status
);
//
console.log('[DT:' + dt_name + ' STATUS]\t\t: ' + dt_resp.status);
}
idx
++
;
...
...
@@ -181,8 +181,8 @@ JobTask.prototype.run = function ()
var
dm_o
=
domain
.
create
();
dm_o
.
on
(
'error'
,
function
(
err
)
{
console
.
log
(
'[DO] plugins error'
);
console
.
log
(
err
);
//
console.log('[DO] plugins error');
//
console.log(err);
callback
({
'status'
:
'error'
,
'data'
:
'plugins error'
});
});
...
...
@@ -205,18 +205,18 @@ JobTask.prototype.run = function ()
//self.emit('error',new Error('job execution timeout'))
},
self
.
job_timeout
);
console
.
log
(
'***** JOB RUNNING *****'
);
console
.
log
(
'[JOB ID]
\
t
\
t: '
+
job_id
);
console
.
log
(
'[TRANSACTION ID]
\
t: '
+
transaction_id
);
//
console.log('***** JOB RUNNING *****');
//
console.log('[JOB ID]\t\t: ' + job_id);
//
console.log('[TRANSACTION ID]\t: ' + transaction_id);
async
.
waterfall
([
task_di
,
task_dt
,
task_do
],
function
(
err
,
resp
)
{
clearTimeout
(
jtimeout
);
if
(
!
err
){
self
.
stop
(
resp
)
console
.
log
(
'***** JOB SUCCESSFULLY DONE *****
\
n'
);
//
console.log('***** JOB SUCCESSFULLY DONE *****\n');
}
else
{
self
.
stop
(
err
)
console
.
log
(
'***** JOB UNSUCCESSFULLY DONE *****
\
n'
);
//
console.log('***** JOB UNSUCCESSFULLY DONE *****\n');
}
});
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment