View Source Lightning.Workflows.Snapshot (Lightning v2.10.4)

Ecto model for Workflow Snapshots.

Snapshots are a way to store the state of a workflow at a given point in time.

Summary

Functions

build(workflow)

create(workflow)

get_all_by_ids(ids)

get_all_for(workflow)

get_by_version(workflow_id, version)

get_current_for(workflow)

Get the latest snapshot for a workflow, based on the lock_version.

get_or_create_latest_for(workflow, actor)

Get the latest snapshot for a workflow, or create one if it doesn't exist.

get_or_create_latest_for(multi, name \\ :snapshot, workflow, actor)

new(workflow)

Types

t()

@type t() :: %Lightning.Workflows.Snapshot{
  __meta__: Ecto.Schema.Metadata.t(),
  edges: [
    %Lightning.Workflows.Snapshot.Edge{
      condition_expression: term(),
      condition_label: term(),
      condition_type: term(),
      enabled: term(),
      id: term(),
      inserted_at: term(),
      source_job_id: term(),
      source_trigger_id: term(),
      target_job_id: term(),
      updated_at: term()
    }
  ],
  id: Ecto.UUID.t() | nil,
  inserted_at: term(),
  jobs: [
    %Lightning.Workflows.Snapshot.Job{
      adaptor: term(),
      body: term(),
      credential: term(),
      id: term(),
      inserted_at: term(),
      name: term(),
      project_credential: term(),
      project_credential_id: term(),
      updated_at: term()
    }
  ],
  lock_version: term(),
  name: String.t() | nil,
  triggers: [
    %Lightning.Workflows.Snapshot.Trigger{
      comment: term(),
      cron_expression: term(),
      custom_path: term(),
      enabled: term(),
      has_auth_method: term(),
      id: term(),
      inserted_at: term(),
      kafka_configuration: term(),
      type: term(),
      updated_at: term(),
      webhook_auth_methods: term()
    }
  ],
  workflow:
    nil | Lightning.Workflows.Workflow.t() | Ecto.Association.NotLoaded.t(),
  workflow_id: term()
}