alecodes/synchronizator
3
0
Fork 0
Code Issues 4 Pull requests Projects Releases Packages Wiki Activity Actions

[Feature]: Task Queue #7

New issue
Open
opened 2025-12-31 14:23:34 -03:00 by aleidk · 1 comment
aleidk commented 2025-12-31 14:23:34 -03:00
Owner
Copy link

Type of Feature

✨ New Feature

Description

As a user I want to enqueue task for it's execution, handling possible failures.__

Completion criteria

  • Create a generic (trait) type called "payload" to store the task data in json format
    • Needs to be serializable by serde to be able to move the data remotely and store it in databases
    • Needs to implement the "From" trait to convert between different payloads
  • CRUD
    • Add Task
    • Load Tasks -> upsert tasks from an array of data
    • List Tasks
    • Cancel Task
    • Bulk Cancel Tasks
    • Retry Task
    • Bulk Retry Task
  • Workers
    • Register callback (dummy for now)
    • Execute queue (sync for now)
    • Add logging through tower services
    • Accept run options
      • Pre/Post Hooks callback
      • Rate Limit
      • Retry Policy

Additional Information

No response

### Type of Feature ✨ New Feature ### Description As a user I want to enqueue task for it's execution, handling possible failures.__ ### Completion criteria - [x] Create a generic (trait) type called _"payload"_ to store the task data in json format - Needs to be serializable by serde to be able to move the data remotely and store it in databases - Needs to implement the _"From"_ trait to convert between different payloads - [ ] CRUD - [ ] Add Task - [ ] Load Tasks -> upsert tasks from an array of data - [ ] List Tasks - [ ] Cancel Task - [ ] Bulk Cancel Tasks - [ ] Retry Task - [ ] Bulk Retry Task - [ ] Workers - [ ] Register callback (dummy for now) - [ ] Execute queue (sync for now) - [ ] Add logging through tower services - [ ] Accept run options - Pre/Post Hooks callback - Rate Limit - Retry Policy ### Additional Information _No response_
aleidk added this to the v0.0.1 milestone 2025-12-31 14:23:34 -03:00
aleidk added the
Priority
High
Severity
Low
Type
Feature
Status
Pending
 labels 2025-12-31 14:23:34 -03:00
ame was assigned by aleidk 2025-12-31 14:23:34 -03:00
aleidk added
Status
Accepted
 and removed
Status
Pending
 labels 2025-12-31 14:46:17 -03:00
aleidk changed reference from development to refactor/new-core-lib 2026-01-02 17:45:31 -03:00
aleidk started working 2026-01-02 17:45:33 -03:00
aleidk stopped working 2026-01-02 22:50:48 -03:00
5 hours 5 minutes
aleidk commented 2026-01-02 22:51:53 -03:00
Author
Owner
Copy link

Create a mapping of the TaskSinkError and the crate custom error enum or use anyhow

Create a mapping of the [TaskSinkError](https://docs.rs/apalis-core/1.0.0-rc.1/apalis_core/backend/enum.TaskSinkError.html) and the crate custom error enum or use anyhow
Sign in to join this conversation.
refactor/new-core-lib
Branches Tags
Clear current reference
main
refactor/new-core-lib
development
refactor/re-structure-project
Clear current reference
No results found.
Labels
Clear labels
  
Outtakes/Blog Post

This can be used as a blog post content

  
Outtakes/Research

This can be further investigated

  
Outtakes/Resource

This can be used as a wiki resource

  
Priority
Critical
Do it now

  
Priority
High
Do it next

  
Priority
Low
It may be done

  
Priority
Medium
Do it when posible

  
Severity
Critical
Is provocking harmfull behavior

  
Severity
High
Is blocking or un-usable

  
Severity
Low
Is inconvinient

  
Severity
Medium
Is Broken with a workarround

  
Status
Abandoned
Work has been done but later abandoned

  
Status
Accepted
This has been reviwed and accepted

  
Status
Blocked
Something is blocking this

  
Status
Need More Info
Research or feedback is required to continue

  
Status
Out Of Scope
This is out of the [current] scope

  
Status
Pending
In waiting of evaluation

  
Status
Won't do
This will not be implemented

  
Type
Bug
Something is not working

  
Type
Documentation
Documentation changes

  
Type
Feature
New functionality

  
Type
Idea
Just an idea for now

  
Type
Testing
Needs testing

No labels
Outtakes/Blog Post
Outtakes/Research
Outtakes/Resource
Priority
Critical
Priority
High
Priority
Low
Priority
Medium
Severity
Critical
Severity
High
Severity
Low
Severity
Medium
Status
Abandoned
Status
Accepted
Status
Blocked
Status
Need More Info
Status
Out Of Scope
Status
Pending
Status
Won't do
Type
Bug
Type
Documentation
Type
Feature
Type
Idea
Type
Testing
Milestone
Clear milestone
No items
No milestone
v0.0.1
Projects
Clear projects
No items
No project
Assignees
Clear assignees
No assignees
ame
1 participant
Notifications
Total time spent: 5 hours 5 minutes
aleidk
5 hours 5 minutes
Due date
The due date is invalid or out of range. Please use the format "yyyy-mm-dd".

No due date set.

Dependencies

No dependencies set.

Reference: alecodes/synchronizator#7
No description provided.
Delete branch "%!s()"

Deleting a branch is permanent. Although the deleted branch may continue to exist for a short time before it actually gets removed, it CANNOT be undone in most cases. Continue?