Takes jobs from a queue and runs them.

Add one to your supervision tree alongside a client:

children = [
  {Zizq, name: MyApp.Zizq, url: "http://localhost:7890"},
  {Zizq.Worker,
   client: MyApp.Zizq,
   queues: ["emails"],
   concurrency: 25,
   handler: &MyApp.handle_job/1}
]

The handler

A one-argument function receiving a Zizq.Job. What it returns decides what happens to the job:

Snooze durations are milliseconds, as every duration in this client is, so {:snooze, :timer.minutes(5)} says plainly what {:snooze, 300_000} means. Note that if you are coming from Oban, Oban's equivalent is in seconds; take care if porting jobs from Oban to Zizq.

Anything else is acknowledged as complete and logged as a warning naming what was returned. Failing the job instead would be worse — the handler most likely did its work and ended on the wrong value, e.g. due to a Logger call, so failing would re-run a side effect that already happened. Return :ok explicitly to keep the log quiet.

Isolation

Each job runs in its own supervised task. A handler that raises, exits, or is killed outright cannot take the worker down — the crash is reported to the server as a failure and the next job starts. A slow handler cannot block the stream from being read either.

Shutdown

On shutdown the worker stops taking new work, waits for running jobs to finish, flushes outstanding acknowledgements, and only then closes the connection — in that order, so the server keeps the in-flight jobs until the acknowledgements arrive. Anything still running when :drain_timeout expires is abandoned and redelivered later.