View Source Lightning.Run (Lightning v2.10.4)

Ecto model for Runs.

Summary

Functions

Adds options (project-level logging options, resource limits such as timeout and memory usage, etc.) to the run before storing in the DB.

Returns the list of final states for a run.

Types

@type t() :: %Lightning.Run{
  __meta__: Ecto.Schema.Metadata.t(),
  claimed_at: term(),
  created_by: term(),
  created_by_id: term(),
  dataclip: term(),
  dataclip_id: term(),
  error_type: term(),
  finished_at: term(),
  id: Ecto.UUID.t() | nil,
  inserted_at: term(),
  log_lines: term(),
  options: term(),
  priority: term(),
  run_steps: term(),
  snapshot: term(),
  snapshot_id: term(),
  started_at: term(),
  starting_job: term(),
  starting_job_id: term(),
  starting_trigger: term(),
  starting_trigger_id: term(),
  state: term(),
  steps: term(),
  updated_at: term(),
  work_order: Lightning.WorkOrder.t() | Ecto.Association.NotLoaded.t(),
  work_order_id: term(),
  workflow: term()
}

Functions

Link to this function

add_options(changeset, project_id)

View Source

Adds options (project-level logging options, resource limits such as timeout and memory usage, etc.) to the run before storing in the DB.

@spec complete(
  %Lightning.Run{
    __meta__: term(),
    claimed_at: term(),
    created_by: term(),
    created_by_id: term(),
    dataclip: term(),
    dataclip_id: term(),
    error_type: term(),
    finished_at: term(),
    id: term(),
    inserted_at: term(),
    log_lines: term(),
    options: term(),
    priority: term(),
    run_steps: term(),
    snapshot: term(),
    snapshot_id: term(),
    started_at: term(),
    starting_job: term(),
    starting_job_id: term(),
    starting_trigger: term(),
    starting_trigger_id: term(),
    state: term(),
    steps: term(),
    updated_at: term(),
    work_order: term(),
    work_order_id: term(),
    workflow: term()
  },
  %{optional(any()) => any()}
) :: Ecto.Changeset.t()
Link to this macro

final_states()

View Source (macro)

Returns the list of final states for a run.