Returns an %Ecto.Changeset{} for tracking job changes.

Examples

iex> change_job(job)
%Ecto.Changeset{data: %Job{}}

Creates a job.

Examples

iex> create_job(%{field: value})
{:ok, %Job{}}

iex> create_job(%{field: bad_value})
{:error, %Ecto.Changeset{}}

@spec get_downstream_jobs_for(
  Lightning.Workflows.Job.t() | Ecto.UUID.t(),
  Lightning.Workflows.Edge.edge_condition() | nil
) :: [Lightning.Workflows.Job.t()]

Returns the list of downstream jobs for a given job, optionally matching a specific trigger type. When downstream_jobs_for is called without a trigger that means its between jobs when it called with a trigger that means we are starting from outside the pipeline

Gets a single job.

Raises Ecto.NoResultsError if the Job does not exist.

Examples

iex> get_job!(123)
%Job{}

iex> get_job!(456)
** (Ecto.NoResultsError)

@spec get_upstream_jobs_for(Lightning.Workflows.Job.t()) :: [
  Lightning.Workflows.Job.t()
]

Returns the list of jobs excluding the one given.

Returns the list of jobs.

Updates a job.

Examples

iex> update_job(job, %{field: new_value})
{:ok, %Job{}}

iex> update_job(job, %{field: bad_value})
{:error, %Ecto.Changeset{}}