Skip to content

Commit ee4b05a

Browse files
committed
Rename jobStatus to jobResult
1 parent 5414172 commit ee4b05a

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

examples/TaskStatusRedis/functions.js

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -44,8 +44,8 @@ async function job_status_redis_test(ins, outs, context, cb) {
4444

4545
// wait for the job to finish (timeout=0 means indefinite)
4646
try {
47-
var jobStatus = await context.jobStatus(0);
48-
console.log('Received job status:', jobStatus);
47+
var jobResult = await context.jobResult(0);
48+
console.log('Received job result:', jobResult);
4949
setTimeout(function() {
5050
cb(null, outs);
5151
}, 5000);

wflib/index.js

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1575,7 +1575,7 @@ function public_invokeProcFunction(wfId, procId, firingId, insIds_, insValues, o
15751575
// should be set by the task's executor
15761576
// Create duplicate redis client for blocking blpop (one per task)
15771577
var redisCliBlocking = rcl.duplicate();
1578-
var getJobStatus = async function(timeout) {
1578+
var getJobResult = async function(timeout) {
15791579
return new Promise(function(resolve, reject) {
15801580
const taskId = conf.taskId;
15811581
const redis_cli = redisCliBlocking;
@@ -1589,7 +1589,7 @@ function public_invokeProcFunction(wfId, procId, firingId, insIds_, insValues, o
15891589
});
15901590
}
15911591

1592-
conf.jobStatus = getJobStatus;
1592+
conf.jobResult = getJobResult;
15931593
conf.redis_url = "redis://" + rcl.address;
15941594

15951595
var sendMessageToJob = async function(message) {

0 commit comments

Comments
 (0)