EctoJob.Worker (ecto_job v3.1.0) View Source

Worker module responsible for executing a single Job

Link to this section Summary

Types

Functions

Equivalent to start_link(config, job, DateTime.utc_now())

Start a worker process given a repo module and a job struct This may fail if the job reservation has expired, in which case the job will be reactivated by the producer.

Link to this section Types

repo()

Specs

repo() :: module()

Link to this section Functions

start_link(config, job)

Specs

start_link(EctoJob.Config.t(), EctoJob.JobQueue.job()) :: {:ok, pid()}

Equivalent to start_link(config, job, DateTime.utc_now())

start_link(config, job, now)

Specs

start_link(EctoJob.Config.t(), EctoJob.JobQueue.job(), DateTime.t()) ::
  {:ok, pid()}

Start a worker process given a repo module and a job struct This may fail if the job reservation has expired, in which case the job will be reactivated by the producer.