module Prostore::Steps::Executor

Overview

Executes a single Step against the database, then updates prostore_schema to reflect the new state.

Each step runs in its own transaction (per Steps.requires_transaction?), and prostore_schema is updated in the same transaction so the bookkeeping stays consistent with the DDL outcome. Step status, lease heartbeats, and resume are handled by the migration runner.

Extended Modules

Defined in:

prostore/steps/executor.cr

Instance Method Summary

Instance Method Detail

def execute(adapter : Prostore::Adapter::Base, conn : DB::Connection, step : Kind::Any, pk_lookup : Hash(String, Array(String)) = {} of String => Array(String), model_lookup : Hash(String, Prostore::Model.class) = {} of String => Prostore::Model.class) : Nil #

[View source]