Comments (2)
i have the same issue, trying to run agenda so pipelines are processed in sequential manner (concurrency 1 )
if i bombard it with request it starts skipping files and keeping them at 'Queued ' state .
did you find a solution ?
from agenda.
Yes, I found it, in my case using Nestjs I abstracted a global service from the Agenda, it turns out that the order in which nestjs initialized the modules it tried to register the queue before creating the global module, what I did was remove the global module and import as a dependency on the modules that use my agenda module. My agenda module is basically a initializer
I removed the global here
import { Module } from '@nestjs/common';
import { AgendaService } from './agenda.service';
@Module({
providers: [AgendaService],
exports: [AgendaService],
})
export class AgendaModule {}
import { Injectable, OnModuleInit } from '@nestjs/common';
import { Agenda, Job } from 'agenda';
export interface JobDefinition {
name: string;
handler: (job: Job) => Promise<void>;
}
@Injectable()
export class AgendaService implements OnModuleInit {
private agenda: Agenda;
async onModuleInit() {
this.agenda = new Agenda({
db: {
address:
'mongodb+srv://root:[email protected]/?retryWrites=true&w=majority&appName=reload-api',
collection: 'agendaJobs',
},
});
await new Promise<void>((resolve, reject) => {
this.agenda.on('ready', () => {
resolve();
});
this.agenda.on('error', (error) => {
console.error('Erro ao inicializar agenda:', error);
reject(error);
});
});
await this.agenda.start();
}
getAgenda(): Agenda {
return this.agenda;
}
}
from agenda.
Related Issues (20)
- Agenda repeatEvery('10 seconds') fails processing remaining jobs
- Longer schedule time (more than one hour from current date or next hour) not triggering
- TimeoutOverflowWarning: 2428508862 does not fit into a 32-bit signed integer.
- Agenda sometimes dont restart the job execution
- Canceling jobs HOT 2
- It seems agenda doesn't connect with mongoose 7.x. Any plans to make it compatible with newer versions of mongoose? HOT 1
- Is there a way to update a job's original payload?
- Questions: REST API - safe to instantiate a new Agenda at each received request? Every can handle only a single job at a time? HOT 1
- With pm2 lots of connections are always open HOT 1
- "mongoose": "^8.0.4" and "agenda": "^5.0.0", getting error HOT 2
- RIP HOT 9
- Scheduled job runs multiple times HOT 3
- Unable to build typescript project with Agenda HOT 2
- Agenda 5.0.0 not compatible with Mongoose 8.2.1 HOT 2
- await agenda.start() waits infinitely while connecting using an existing MongoClient instance HOT 2
- Concurrency issue - Urgent Help Us HOT 1
- Job runs multiple times HOT 5
- drain() is not documented
- [Error] job lock failed while filling queue TypeError: Cannot read properties of null (reading 'value') HOT 1
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from agenda.