Oban.Pro.Workers.Workflow behaviour (Oban Pro v1.5.0-rc.0)

This behaviour is deprecated. Use Oban.Pro.Workflow instead.

A dedicated worker for linking the execution of jobs.

This worker is deprecated in favor of Oban.Pro.Workflow, which is more flexible and supports more options.

Summary

Callbacks

add(t, name, changeset, list)
after_cancelled(cancel_reason, t)
all_workflow_jobs(t, list)
append_workflow(arg1, list)
gen_id()
new_workflow(list)
stream_workflow_jobs(t, list)
to_dot(t)

Callbacks

Link to this callback

add(t, name, changeset, list)

@callback add(Oban.Pro.Workflow.t(), Oban.Pro.Workflow.name(), Oban.Job.changeset(), [
  Oban.Pro.Workflow.add_option()
]) :: Oban.Pro.Workflow.t()
Link to this callback

after_cancelled(cancel_reason, t)

(optional) 
@callback after_cancelled(Oban.Pro.Workflow.cancel_reason(), Oban.Job.t()) :: :ok
Link to this callback

all_workflow_jobs(t, list)

@callback all_workflow_jobs(Oban.Job.t(), [Oban.Pro.Workflow.fetch_option()]) :: [
  Oban.Job.t()
]
Link to this callback

append_workflow(arg1, list)

@callback append_workflow(Oban.Job.t() | [Oban.Job.t()], [
  Oban.Pro.Workflow.append_option()
]) ::
  Oban.Pro.Workflow.t()
Link to this callback

gen_id()

@callback gen_id() :: String.t()
Link to this callback

new_workflow(list)

@callback new_workflow([Oban.Pro.Workflow.new_option()]) :: Oban.Pro.Workflow.t()
Link to this callback

stream_workflow_jobs(t, list)

@callback stream_workflow_jobs(Oban.Job.t(), [Oban.Pro.Workflow.fetch_option()]) ::
  Enum.t()
Link to this callback

to_dot(t)

@callback to_dot(Oban.Pro.Workflow.t()) :: String.t()