766 questions
1
vote
1
answer
83
views
Why is the worker's onmessage executing after a macro task?
Event loop execution order
I'm studying how the Javascript event loop works for a future presentation, but I've come across an unexpected behavior with the information I have so far. Simply put, when ...
- 13
1
vote
0
answers
24
views
MongoDB and celery configuration
I am new to celery and there isn't alot of great documentation to follow esepcially with mongodb.
I am essentially trying to have celery post messages to two different collections based on where ...
0
votes
1
answer
105
views
Task Queue: Release all messages at once to a single consumer when threshold is met
I'm looking for a task queue that supports pushing tasks into a queue and only releasing them to a single consumer at a time when a threshold number of messages is reached. When released to the ...
- 53
0
votes
0
answers
57
views
Celery picks up new tasks, but all old are stuck in PENDING
In a nutshell: I'm able to run new celery tasks but the old ones are stuck with PENDING states.
Celery run command:
celery -A config.celery_app worker --pool=solo --loglevel=info
Environment:
Celery ...
- 342
-1
votes
1
answer
28
views
Any HTTP/HTTPs supported Messaging or Queuing system available?
Friends,
I am looking for Messaging/Queuing service, preferably opensource that supports Queuing-Dequeuing over HTTP(its a must). I know there are a lot of Cloud based services(AWS SQS, Azure EventHub)...
- 307
0
votes
1
answer
118
views
How to Implement Conditional Task Execution in Celery from API Registration?
I’m building an API that registers tasks to Celery, and I want to implement a conditional workflow based on the results of the tasks. Specifically, I need to execute Task B if Task A returns a certain ...
0
votes
2
answers
93
views
Job scheduling and deduplicating events in an in-memory task queue pattern with .NET 8
I have a database of messages that I want to send. Each has a unique message identifier and is placed in the database by another process. The only communication between the two processes is via the ...
- 697
-4
votes
2
answers
154
views
Async operation like fetch, async/await are executed after syncronous code is executed then why microtask queue is given more priority?
micro task Queue consist of callbacks/resolved functions from fetch, async/await. but why its given more priority then callback queue because sync code is executed first and then afterward async ...
1
vote
0
answers
236
views
Is the Bull queue in NestJS the best solution for this situation? (best practice)
I have a back-end built with NestJS and MongoDB, where I'm utilizing microservices to communicate with other services.
I have a POST endpoint that handles complex logic:
First, I retrieve data from ...
- 11
-3
votes
1
answer
48
views
Why does 1 is printed before 4 in this execution of js code?
async function check() {
await Promise.resolve(console.log(1));
console.log(2);
}
console.log(3);
check();
console.log(4);
The answer is 3,1,4,2
As I know the async function will go to web API to ...
0
votes
0
answers
86
views
FreeRTOS: Simple Queue program, values of Queue are not being printed on Serial Monitor
I'm using FreeRTOS on the Adafruit HUZZAH32 – ESP32 Feather Board, and programming on the Arduino IDE.
The goal of this simple Queue program is to create a Queue, populate it sending values of an ...
- 8,849
0
votes
1
answer
153
views
Task Queue with cached libraries in Django
I am creating a WEB interface for various Python scripts through Django.
Example in calculation.py I would have :
import datetime
def add_time(a, b):
return = a + b + int(datetime.datetime.now())
...
- 378
0
votes
0
answers
686
views
Celery Alternatives based on DAG
I am building a product that uses Kubernetes. Now a user can submit requests to this cluster, which kicks off a bunch of potentially long-running tasks. I initially had intended to use Celery for this ...
- 133
1
vote
1
answer
184
views
Kubernetes: Infinite Workload Using One Pod Per Task
I’m trying to create something similar to Lambda functions on kubernetes.
I need to run each request on a separate pod. Once the container terminates successfully, the response is returned and the pod ...
- 11
2
votes
0
answers
162
views
Where does the concept of macrotasks come from in the browser? [closed]
In many articles about the browser's event loop, the concept of macrotasks and microtasks is mentioned. But I looked at the description of event loops in the HTML spec, where there is no concept of ...
- 21
