Hello *, I’m a little confused by how Toniq works.
I can read on the documentation that I can actually use pipelines to queue jobs (GitHub - joakimk/toniq: Simple and reliable background job processing library for Elixir. · GitHub) using the enqueue_to function.
If I try once everything works like a charm, my jobs are enqueued and run. If I try more than once it fails because the second worker receives a different data structure.
I solved with Enum.map, but honestly I’m not in love with my solution:

Enum.map([Service.Macaw.CreationWorker, Service.Gannet.CreationWorker],
         fn(worker) -> Toniq.enqueue(worker, service) end)

I would obviously prefer something like:

service
|> Toniq.enqueue_to(Service.Macaw.CreationWorker)
|> Toniq.enqueue_to(Service.Gannet.CreationWorker)

which seems much more idiomatic.

Suggestions?
ngw