@type status() ::
  :pending
  | :running
  | :completed
  | :failed
  | :waiting
  | :cancelled
  | :compensating
  | :compensated
  | :compensation_failed

@type t() :: %Durable.Storage.Schemas.WorkflowExecution{
  __meta__: term(),
  compensated_at: DateTime.t() | nil,
  compensation_results: [map()],
  completed_at: DateTime.t() | nil,
  context: map(),
  current_step: String.t() | nil,
  error: map() | nil,
  id: Ecto.UUID.t(),
  input: map(),
  inserted_at: DateTime.t(),
  lock_token: term(),
  locked_at: DateTime.t() | nil,
  locked_by: String.t() | nil,
  parent_workflow_id: Ecto.UUID.t() | nil,
  pending_inputs: term(),
  priority: integer(),
  queue: String.t(),
  scheduled_at: DateTime.t() | nil,
  started_at: DateTime.t() | nil,
  status: status(),
  step_executions: term(),
  updated_at: DateTime.t(),
  workflow_module: String.t(),
  workflow_name: String.t()
}