Class: CreateNexoWorkflowRuns

Inherits:
Object
  • Object
show all
Defined in:
lib/generators/nexo/workflows/templates/create_nexo_workflow_runs.rb

Overview

json columns are used everywhere (not jsonb) so the schema is portable across SQLite and PostgreSQL without an adapter-aware path. The primary key is the UUID string id assigned by Nexo::WorkflowRun before_create.

Instance Method Summary collapse

Instance Method Details

#change ⇒ Object

Creates the nexo_workflow_runs table (UUID string primary key, portable json columns for payload/result/events/artifacts/state) plus indexes on workflow_class and status.



10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
 
# File 'lib/generators/nexo/workflows/templates/create_nexo_workflow_runs.rb', line 10

def change
  create_table :nexo_workflow_runs, id: false do |t|
    t.string :id, null: false, primary_key: true
    t.string :workflow_class, null: false
    t.string :status, null: false, default: "pending" # pending|running|done|failed|suspended
    t.json :payload, null: false, default: {}
    t.json :result
    t.text :error
    t.json :events, null: false, default: []
    t.json :artifacts, null: false, default: []
    t.json :state, null: false, default: {} # checkpoints + suspend metadata (Spec 13)
    t.timestamps
  end
  add_index :nexo_workflow_runs, :workflow_class
  add_index :nexo_workflow_runs, :status
end