removeOnComplete(true) does not delete job when it is done

[mmarshak]

I can not make the job auto removed when complete.

I define the job as - job = Queue.createJob(type, payload) .attempts(3) .backoff( {delay: 10*1000, type:'fixed'} ) // // back of 10 seconds after each failure .priority('normal') .removeOnComplete(true);

And I use schedule to run it one time (not every) but it does not delete the job automatically. When I use just Kue instead it does. Any guidance ?

[mmarshak]

Does somebody have it working?

[lykmapipo]

@mmarshak I have the same problem and I will work to fix it.

[mmarshak]

Thanks

[lykmapipo]

@mmarshak May please add a fail test(spec) for this so that i can work around your specification.

Appreciated.

[mmarshak]

Hi @lykmapipo,

As I wrote in my post if I create the job, I expect that cue-scheduler will delete the job when it complete, but it does not.

job = Queue.createJob(type, payload) .attempts(3) .backoff( {delay: 10*1000, type:'fixed'} ) // // back of 10 seconds after each failure .priority('normal') .removeOnComplete(true);

So in my implementation I comment out the - .removeOnComplete(true); And in order to clean the complete job I am listening to Queue events for the event 'job complete', and then I delete the job, which works.

Bellow is the code I use for that -

// Queue events Queue.on('job enqueue', function(id, type){

    //console.log( "Queue-Job job# " +id + " got queued of type " + type );
    logKue( "Queue-Job job# " +id + " got queued of type " + type );

}).on('job complete', function(id, result){

    //console.log("Queue-Job job# " + id + " completed with data " +  util.inspect(result));
    logKue("Queue-Job job# " + id + " completed with data " +  util.inspect(result));
    //logKue("Queue-Job job# " + id + " completed ");

    // Remove the job upon its completion
    kue.Job.get(id, function(err, job){
        if (err) {
            return;
        }

        job.remove(function(err){
          if (err) {
            logError("Failed to remove job %s after it was completed, got an error %s", job.id, util.inspect(err));     
          }
          else {
            log('removed completed job #%d', job.id);
            //console.log('removed completed job #%d', job.id);
          }
        });
      });

It will be great if the .removeOnComplete(true); was doing it job as it does for the regular Kue. I am sure it will make other people easier.

Thanks

[banduk]

Same problem here.

Any updateon that?

[rodrigooler]

Same problem here.

[lykmapipo]

@rodrigooler Please use latest version. I merged #124. Hope it will fix the issue.