-
Notifications
You must be signed in to change notification settings - Fork 16
Job.log
Grant Carthew edited this page Feb 10, 2017
·
8 revisions
Get: Array
- Returns an array of
log
entries.
Example:
const Queue = require('rethinkdb-job-queue')
const q = new Queue()
let job = q.createJob()
q.addJob(job).then(() => {
return q.getJob(job.id)
}).then((savedJobs) => {
// savedJobs[0].log.length === 1
}).catch(err => console.error(err))
For more detail see the Job.addLog and Job Logging documents.
To give you an idea of what the Job.log
property will return, here is a job from the database created during the process tests.
{
"dateCreated": Sun Oct 09 2016 22:57:18 GMT+00:00 ,
"dateEnable": Sun Oct 09 2016 22:57:36 GMT+00:00 ,
"dateFinished": Sun Oct 09 2016 22:57:30 GMT+00:00 ,
"dateStarted": Sun Oct 09 2016 22:57:29 GMT+00:00 ,
"id": "c8536c2a-4fc9-42d0-9ee0-3b8f6a876ed4" ,
"log": [
{
"data": null ,
"date": Sun Oct 09 2016 22:57:18 GMT+00:00 ,
"message": "Job added to the queue" ,
"queueId": "WebDev:rjqJobQueueTests:rjqJobQueueTestJobs:1460:d464d60d-1fff-48ce-9a64-3a988b4a3f6b" ,
"retryCount": 0 ,
"status": "waiting" ,
"type": "information"
} ,
{
"date": Sun Oct 09 2016 22:57:18 GMT+00:00 ,
"message": "Job retrieved and active" ,
"queueId": "WebDev:rjqJobQueueTests:rjqJobQueueTestJobs:1460:d464d60d-1fff-48ce-9a64-3a988b4a3f6b" ,
"retryCount": 0 ,
"status": "active" ,
"type": "information"
} ,
{
"data": {
"message": "Job timed out (run time > 1000 sec)" ,
"name": "Error" ,
"stack": "Error: Job timed out (run time > 1000 sec)
at Timeout.timeoutHandler (/home/grant/node-rethinkdb-job-queue/src/queue-process.js:113:17)
at tryOnTimeout (timers.js:232:11)
at Timer.listOnTimeout (timers.js:202:5)"
} ,
"date": Sun Oct 09 2016 22:57:19 GMT+00:00 ,
"duration": 1027 ,
"errorMessage": "Job timed out (run time > 1000 sec)" ,
"errorStack": "Error: Job timed out (run time > 1000 sec)
at Timeout.timeoutHandler (/home/grant/node-rethinkdb-job-queue/src/queue-process.js:113:17)
at tryOnTimeout (timers.js:232:11)
at Timer.listOnTimeout (timers.js:202:5)" ,
"message": "Job processing failed" ,
"queueId": "WebDev:rjqJobQueueTests:rjqJobQueueTestJobs:1460:d464d60d-1fff-48ce-9a64-3a988b4a3f6b" ,
"retryCount": 1 ,
"status": "failed" ,
"type": "warning"
} ,
{
"date": Sun Oct 09 2016 22:57:20 GMT+00:00 ,
"message": "Job retrieved and active" ,
"queueId": "WebDev:rjqJobQueueTests:rjqJobQueueTestJobs:1460:d464d60d-1fff-48ce-9a64-3a988b4a3f6b" ,
"retryCount": 1 ,
"status": "active" ,
"type": "information"
} ,
{
"data": {
"message": "Job timed out (run time > 1000 sec)" ,
"name": "Error" ,
"stack": "Error: Job timed out (run time > 1000 sec)
at Timeout.timeoutHandler (/home/grant/node-rethinkdb-job-queue/src/queue-process.js:113:17)
at tryOnTimeout (timers.js:232:11)
at Timer.listOnTimeout (timers.js:202:5)"
} ,
"date": Sun Oct 09 2016 22:57:21 GMT+00:00 ,
"duration": 1036 ,
"errorMessage": "Job timed out (run time > 1000 sec)" ,
"errorStack": "Error: Job timed out (run time > 1000 sec)
at Timeout.timeoutHandler (/home/grant/node-rethinkdb-job-queue/src/queue-process.js:113:17)
at tryOnTimeout (timers.js:232:11)
at Timer.listOnTimeout (timers.js:202:5)" ,
"message": "Job processing failed" ,
"queueId": "WebDev:rjqJobQueueTests:rjqJobQueueTestJobs:1460:d464d60d-1fff-48ce-9a64-3a988b4a3f6b" ,
"retryCount": 2 ,
"status": "failed" ,
"type": "warning"
} ,
{
"date": Sun Oct 09 2016 22:57:24 GMT+00:00 ,
"message": "Job retrieved and active" ,
"queueId": "WebDev:rjqJobQueueTests:rjqJobQueueTestJobs:1460:d464d60d-1fff-48ce-9a64-3a988b4a3f6b" ,
"retryCount": 2 ,
"status": "active" ,
"type": "information"
} ,
{
"data": {
"message": "Job timed out (run time > 1000 sec)" ,
"name": "Error" ,
"stack": "Error: Job timed out (run time > 1000 sec)
at Timeout.timeoutHandler (/home/grant/node-rethinkdb-job-queue/src/queue-process.js:113:17)
at tryOnTimeout (timers.js:232:11)
at Timer.listOnTimeout (timers.js:202:5)"
} ,
"date": Sun Oct 09 2016 22:57:25 GMT+00:00 ,
"duration": 1074 ,
"errorMessage": "Job timed out (run time > 1000 sec)" ,
"errorStack": "Error: Job timed out (run time > 1000 sec)
at Timeout.timeoutHandler (/home/grant/node-rethinkdb-job-queue/src/queue-process.js:113:17)
at tryOnTimeout (timers.js:232:11)
at Timer.listOnTimeout (timers.js:202:5)" ,
"message": "Job processing failed" ,
"queueId": "WebDev:rjqJobQueueTests:rjqJobQueueTestJobs:1460:d464d60d-1fff-48ce-9a64-3a988b4a3f6b" ,
"retryCount": 3 ,
"status": "failed" ,
"type": "warning"
} ,
{
"date": Sun Oct 09 2016 22:57:29 GMT+00:00 ,
"message": "Job retrieved and active" ,
"queueId": "WebDev:rjqJobQueueTests:rjqJobQueueTestJobs:1460:d464d60d-1fff-48ce-9a64-3a988b4a3f6b" ,
"retryCount": 3 ,
"status": "active" ,
"type": "information"
} ,
{
"data": {
"message": "Job timed out (run time > 1000 sec)" ,
"name": "Error" ,
"stack": "Error: Job timed out (run time > 1000 sec)
at Timeout.timeoutHandler (/home/grant/node-rethinkdb-job-queue/src/queue-process.js:113:17)
at tryOnTimeout (timers.js:232:11)
at Timer.listOnTimeout (timers.js:202:5)"
} ,
"date": Sun Oct 09 2016 22:57:30 GMT+00:00 ,
"duration": 1030 ,
"errorMessage": "Job timed out (run time > 1000 sec)" ,
"errorStack": "Error: Job timed out (run time > 1000 sec)
at Timeout.timeoutHandler (/home/grant/node-rethinkdb-job-queue/src/queue-process.js:113:17)
at tryOnTimeout (timers.js:232:11)
at Timer.listOnTimeout (timers.js:202:5)" ,
"message": "Job processing failed" ,
"queueId": "WebDev:rjqJobQueueTests:rjqJobQueueTestJobs:1460:d464d60d-1fff-48ce-9a64-3a988b4a3f6b" ,
"retryCount": 3 ,
"status": "terminated" ,
"type": "error"
}
] ,
"priority": 40 ,
"progress": 0 ,
"queueId": "WebDev:rjqJobQueueTests:rjqJobQueueTestJobs:1460:d464d60d-1fff-48ce-9a64-3a988b4a3f6b" ,
"retryCount": 3 ,
"retryDelay": 2000 ,
"retryMax": 3 ,
"status": "terminated" ,
"timeout": 1000
}
- Introduction
- Tutorial
- Queue Constructor
- Queue Connection
- Queue Options
- Queue PubSub
- Queue Master
- Queue Events
- State Document
- Job Processing
- Job Options
- Job Status
- Job Retry
- Job Repeat
- Job Logging
- Job Editing
- Job Schema
- Job Name
- Complex Job
- Delayed Job
- Cancel Job
- Error Handling
- Queue.createJob
- Queue.addJob
- Queue.getJob
- Queue.findJob
- Queue.findJobByName
- Queue.containsJobByName
- Queue.cancelJob
- Queue.reanimateJob
- Queue.removeJob
- Queue.process
- Queue.review
- Queue.summary
- Queue.ready
- Queue.pause
- Queue.resume
- Queue.reset
- Queue.stop
- Queue.drop
- Queue.Job
- Queue.host
- Queue.port
- Queue.db
- Queue.name
- Queue.r
- Queue.id
- Queue.jobOptions [R/W]
- Queue.changeFeed
- Queue.master
- Queue.masterInterval
- Queue.removeFinishedJobs
- Queue.running
- Queue.concurrency [R/W]
- Queue.paused
- Queue.idle
- Event.ready
- Event.added
- Event.updated
- Event.active
- Event.processing
- Event.progress
- Event.log
- Event.pausing
- Event.paused
- Event.resumed
- Event.completed
- Event.cancelled
- Event.failed
- Event.terminated
- Event.reanimated
- Event.removed
- Event.idle
- Event.reset
- Event.error
- Event.reviewed
- Event.detached
- Event.stopping
- Event.stopped
- Event.dropped
- Job.setName
- Job.setPriority
- Job.setTimeout
- Job.setDateEnable
- Job.setRetryMax
- Job.setRetryDelay
- Job.setRepeat
- Job.setRepeatDelay
- Job.updateProgress
- Job.update
- Job.getCleanCopy
- Job.addLog
- Job.getLastLog