SqlRunStore
Implements
Section titled “Implements”RunStore
Constructors
Section titled “Constructors”Constructor
Section titled “Constructor”new SqlRunStore(sql): SqlRunStore;Parameters
Section titled “Parameters”| Parameter | Type |
|---|---|
|
|
Returns
Section titled “Returns”SqlRunStore
Methods
Section titled “Methods”appendStep()
Section titled “appendStep()”appendStep(runId, record): Promise<void>;Parameters
Section titled “Parameters”| Parameter | Type |
|---|---|
|
|
|
|
|
|
Returns
Section titled “Returns”Promise<void>
Implementation of
Section titled “Implementation of”RunStore.appendStepdeleteRun()
Section titled “deleteRun()”deleteRun(runId, options?): Promise<void>;Parameters
Section titled “Parameters”| Parameter | Type |
|---|---|
|
|
|
|
|
|
Returns
Section titled “Returns”Promise<void>
Implementation of
Section titled “Implementation of”RunStore.deleteRunfinalizeStep()
Section titled “finalizeStep()”finalizeStep( runId, key,patch): Promise<void>;Parameters
Section titled “Parameters”| Parameter | Type |
|---|---|
|
|
|
|
|
|
|
|
|
Returns
Section titled “Returns”Promise<void>
Implementation of
Section titled “Implementation of”RunStore.finalizeStepgetRunState()
Section titled “getRunState()”getRunState(runId): Promise<RunState | null>;Parameters
Section titled “Parameters”| Parameter | Type |
|---|---|
|
|
|
Returns
Section titled “Returns”Promise<RunState | null>
Implementation of
Section titled “Implementation of”RunStore.getRunStategetSteps()
Section titled “getSteps()”getSteps(runId): Promise<StepRecord[]>;Parameters
Section titled “Parameters”| Parameter | Type |
|---|---|
|
|
|
Returns
Section titled “Returns”Promise<StepRecord[]>
Implementation of
Section titled “Implementation of”RunStore.getStepsimportLegacyRuns()
Section titled “importLegacyRuns()”importLegacyRuns(runs): Promise<void>;Copy a pre-SqlRunStore journal from the orchestration blob into the two
tables, skipping any run_id that already has a SQL row. Called once per
wake so a session journaled before this store existed can resume; later
saves stop writing durableRuns so the blob is not a second source of truth.
Parameters
Section titled “Parameters”| Parameter | Type |
|---|---|
|
|
|
Returns
Section titled “Returns”Promise<void>
initRun()
Section titled “initRun()”initRun(state): Promise<void>;Parameters
Section titled “Parameters”| Parameter | Type |
|---|---|
|
|
|
Returns
Section titled “Returns”Promise<void>
Implementation of
Section titled “Implementation of”RunStore.initRunlistRuns()
Section titled “listRuns()”listRuns(filter): AsyncIterable<RunRef>;Parameters
Section titled “Parameters”| Parameter | Type |
|---|---|
|
|
|
Returns
Section titled “Returns”AsyncIterable<RunRef>
Implementation of
Section titled “Implementation of”RunStore.listRunspruneStepsBeforeEpoch()
Section titled “pruneStepsBeforeEpoch()”pruneStepsBeforeEpoch(runId, keepEpoch): Promise<void>;Parameters
Section titled “Parameters”| Parameter | Type |
|---|---|
|
|
|
|
|
|
Returns
Section titled “Returns”Promise<void>
Implementation of
Section titled “Implementation of”RunStore.pruneStepsBeforeEpochputRunState()
Section titled “putRunState()”putRunState(state): Promise<void>;Parameters
Section titled “Parameters”| Parameter | Type |
|---|---|
|
|
|
Returns
Section titled “Returns”Promise<void>
Implementation of
Section titled “Implementation of”RunStore.putRunStatereserveSteps()
Section titled “reserveSteps()”reserveSteps(runId, count): Promise<number[]>;Parameters
Section titled “Parameters”| Parameter | Type |
|---|---|
|
|
|
|
|
|
Returns
Section titled “Returns”Promise<number[]>
Implementation of
Section titled “Implementation of”RunStore.reserveSteps