Given the current task ID, is it possible to reschedule the current task?

[JasterV]

So, I want to handle retries myself instead of leveraging it to the automatic retry system of apalis.

I'm using the postgres backend.

How would you approach this?

My goal would be: Fetch the current task ID, then if an error occur, use this task ID to somehow reschedule the current task.

[geofmureithi]

You should be able to write your own retry policy eg:

https://docs.rs/apalis/1.0.0-rc.8/src/apalis/layers/retry/mod.rs.html#267-299

Then you can pass it to the .retry method:

https://docs.rs/apalis/1.0.0-rc.8/apalis/layers/retry/#example-worker-with-retry-policy

[JasterV]

This doesn't fit my use case though, because I am building an application following an hexagonal architecture pattern, and the retry logic is implemented inside the "hexagon"

This means that moving the retry logic to the "outside", meaning the apalis worker definition, is not what I am looking for. Because retrying a job in my specific case is a core part of my business logic.

What I mean by this is that I'd like to be able to do something like:

storage.reschedule(task_id, run_at)

Or at least something like:

let task = storage.get_task(task_id);
storage.reschedule(task, run_at);

I hope this makes sense

[geofmureithi]

If you are using postgres, you can use an sql query:

This is the ack query, you can use something similar

UPDATE
    apalis.jobs
SET
    status = $4,
    attempts = $2,
    last_result = $3,
    done_at = NOW()
WHERE
    id = $1
    AND lock_by = $5

[JasterV]

alright sounds good! :)

What will happen though when the task handler finishes? Won't apalis automatically overwrite the last_result and status?

[geofmureithi]

Are you speaking of a running task? You want to reschedule a running task? If so, I encourage you to make sure the running task is stopped first. Else you will experience race conditions.

[JasterV]

Yes exactly, that is what I'm asking, and it does make sense that we would run into a race condition

I will try to give it a thought, probably what I'm looking for doesn't make sense logically