Make a taskqueue provider with pluggable backends (redis streams, sqs, etc.).
For now make a RedisSource that we can use in here.
It will have the following endpoints:
/sc/v1/tasks/{queueName}/fetch
Get list of tasks for that queue
By default it will return the number of tasks configured in the TaskQueue Resource. But have the ability to override the number of tasks via an query param limit
/sc/v1/tasks/{queueName}/ack/{id}
marks a task as complete or failed
/sc/v1/tasks/{queueName}/status
Gets number of pending tasks in queue
Gets number of tasks being processed
If you want this feature to be implemented, give it a thumbs up reaction, so that we can determine which features are important to you.
👍
The problem faced currently?
No way to schedule and track asynchronous tasks.
How can we solve it?
RedisSource
that we can use in here./sc/v1/tasks/{queueName}/fetch
TaskQueue
Resource. But have the ability to override the number of tasks via an query paramlimit
/sc/v1/tasks/{queueName}/ack/{id}
/sc/v1/tasks/{queueName}/status