Packages

queuetopia

2.3.2
2.7.2 2.7.1 2.7.0 2.6.1 2.6.0 2.5.3 2.5.2 2.5.1 2.5.0 2.4.4 2.4.3 2.4.2 2.4.1 2.4.0 2.3.5 2.3.3 2.3.2 2.3.1 2.3.0 2.2.0 2.1.3 2.1.2 2.1.1 2.1.0 2.0.1 2.0.0 1.7.0 1.6.0 1.5.1 1.5.0 1.4.0 1.3.1 1.3.0 1.2.0 1.1.3 1.1.2 1.1.1 1.1.0 1.0.0 0.6.3 0.6.2 0.6.1 0.6.0 0.5.1 0.5.0 0.3.0 0.2.0 0.1.2

Persistent blocking job queue

HexDocs

Current section

Files

Jump to
Readme
48 Versions
3 Dependencies
Dependants
Files
Activity
queuetopia lib queuetopia migrations v3.ex
Raw

lib/queuetopia/migrations/v3.ex 

defmodule Queuetopia.Migrations.V3 do

  @moduledoc false



  use Ecto.Migration



  def up do

    query =

      case repo().__adapter__() do

        Ecto.Adapters.Postgres ->

          "ALTER TABLE queuetopia_jobs ADD COLUMN next_attempt_at timestamp;"



        Ecto.Adapters.MyXQL ->

          "ALTER TABLE queuetopia_jobs ADD COLUMN next_attempt_at datetime AFTER attempted_by;"

      end



    execute(query)

  end



  def down do

    alter table("queuetopia_jobs") do

      remove(:next_attempt_at)

    end

  end

end