v3.1.0

Version 3.1.0 adds

• support for storing jobs in MySQL 8, thanks @jeanparpaillon !
• persisting job params as an Elixir/Erlang term, thanks @lukyanov !

You can insert any arbitrary Elixir/Erlang term into the queue:

{"SendEmail", "jonas@gmail.com", "Welcome!"}
|> MyApp.JobQueue.new()
|> MyApp.Repo.insert()

You should use the option :params_type when defining your queue module:

defmodule MyJobQueue do
  use EctoJob.JobQueue, table_name: "jobs", params_type: :binary
  # ...
end

Possible values of the option are: :map (default) and :binary (for storing Elixir/Erlang terms).

You should use the same option when setting up the migration:

@ecto_job_version 3

def up do
  EctoJob.Migrations.Install.up()
  EctoJob.Migrations.up("jobs", version: @ecto_job_version, params_type: :binary)
end

v3.0.0

Version 3.0 adds support for prioritizing jobs within each job queue.
The priority option can be given when creating a Job:

%{"type" => "SendEmail", "address" => "jonas@gmail.com", "body" => "Welcome!"}
|> MyApp.JobQueue.new(priority: 2, max_attempts: 2)
|> MyApp.Repo.insert()

Lower numbers run first, the default value is 0.

Thanks to ramondelemos for contibuting this feature!

#45 - gabriel128 Failed jobs will retry before the full execution_timeout when an error occurs. By default the first retry will occur 30 seconds after failure.

Thanks to gabriel128 for contributing this feature!

Migrating to 3.0

To upgrade to version 3.0 you must add a migration to update the pre-existent job queue tables:

mix ecto.gen.migration update_job_queue

defmodule MyApp.Repo.Migrations.UpdateJobQueue do
  use Ecto.Migration
  @ecto_job_version 3

  def up do
    EctoJob.Migrations.UpdateJobTable.up(@ecto_job_version, "jobs")
  end
  def down do
    EctoJob.Migrations.UpdateJobTable.down(@ecto_job_version, "jobs")
  end
end

v2.1.0

Version 2.1 add support for requeing jobs, fixes to the job reservation algorithm and dialyzer warnings.

#34 - mkorszun New API to requeue a failed job :

Requeuing will:

• set state to SCHEDULED
• set attempt to 0
• set expires to nil

Ecto.Multi.new()
|> MyApp.Job.requeue("requeue_job", failed_job)
|> MyApp.Repo.transaction()

#43 - mbuhot, seangeo - Fixed issue where too many rows would be locked, causing negative demand in GenStage producer. See this document for additional details.

#41 - mbuhot - Fixed dialyzer warnings in JobQueue modules

#42 - sneako - Improved documentation

#48 - darksheik - Improved documentation

Thankyou contributors!

v2.0.0

EctoJob 2.0 adds support for Ecto 3.0.

There should be no breaking changes other than the dependency on ecto_sql ~> 3.0.

#31 - mbuhot - Timestamp options on job tables can be customized.

#30 - mbuhot - Job tables can be declared with custom schema_prefix.

#29 - mbuhot - EctoJob will always use a :bigserial primary key instead of relying on the ecto default.

v0.2.1

#14 - mbuhot - Improve configuration flexibility

Configuration can be supplied through the supervisor opts, application config, or fallback to defaults.

#15 - mbuhot - Fix dialyzer warnings and improve docs.

Initial Release

This will be the first release to Hex.pm