Scoria.Workflows.BatchEnqueue (scoria v0.1.0)

Copy Markdown View Source

Provides bulk chunking and enqueueing of Oban jobs into target queues.

Summary

Functions

enqueue_all(jobs, opts \\ [])

Enqueues a list of Oban jobs in chunks using Ecto.Multi.

Functions

enqueue_all(jobs, opts \\ [])

Enqueues a list of Oban jobs in chunks using Ecto.Multi.

Options

  • :chunk_size - The number of jobs per chunk (defaults to 500).

Returns

{:ok, results} on success or {:error, failed_operation, failed_value, changes_so_far}.