ok。before i change the cron from */3 * * * * *to */4 * * * * *,i want clean all the jobs in queue bus:accessTokenSchedule。

        await app.bus.get('bus:accessTokenSchedule').obliterate({ force: true });

        //add repeat job 
        await app.bus.dispatch(
          'accessTokenSchedule',
          {},
          {
            jobId: 'accessTokenSchedule',
            repeat: { cron: '*/3 * * * * *' },
            removeOnComplete: true,
          }
        );

but, when i use getRepeatableJobs ,i got 2 jobs

[ { key: '__default__:accessTokenSchedule:::*/3 * * * * *',
    name: '__default__',
    id: 'accessTokenSchedule',
    endDate: null,
    tz: null,
    cron: '*/3 * * * * *',
    every: null,
    next: 1618642071000 },
  { key: '__default__:accessTokenSchedule:::*/4 * * * * *',
    name: '__default__',
    id: 'accessTokenSchedule',
    endDate: null,
    tz: null,
    cron: '*/8 * * * * *',
    every: null,
    next: 1618641676000 } ]

how to clean all the jobs in queue？ #2012

Description

Metadata

Assignees

Labels

Type

Projects

Milestone

Relationships

Development

Issue actions