Class FencedWorkflowsStorageD1

Owned initial admission and repair. On a binding with batch(), unscoped persistence is an owned upsert that refuses to overwrite a settled run row (RunSettledConflictError); otherwise it delegates to the adapter.

Hierarchy (View Summary)

WorkflowsStorageD1
- FencedWorkflowsStorageD1
  - DurableObjectWorkflowsStorageD1

Index

Constructors

Properties

[FENCED_WORKFLOW_STORAGE]?

Methods

persistWorkflowSnapshot withInitialTerminalizationLock

Constructors

constructor

new FencedWorkflowsStorageD1(config: D1DomainConfig): FencedWorkflowsStorageD1
Parameters
- config: D1DomainConfig
Returns FencedWorkflowsStorageD1
Overrides WorkflowsStorageD1.constructor
- Defined in packages/flowsafe/src/do-runner/fenced-workflows-d1.ts:1287

Properties

`Optional` `Readonly`[FENCED_WORKFLOW_STORAGE]

"[FENCED_WORKFLOW_STORAGE]"?: FencedWorkflowAdmissionCapability

Methods

persistWorkflowSnapshot

persistWorkflowSnapshot(args: {}): Promise<void>
Parameters
- args: {}
Returns Promise<void>
Overrides WorkflowsStorageD1.persistWorkflowSnapshot
- Defined in packages/flowsafe/src/do-runner/fenced-workflows-d1.ts:1457

`Protected`withInitialTerminalizationLock

withInitialTerminalizationLock<T>(
    _workflowName: string,
    _runId: string,
    operation: () => Promise<T>,
): Promise<T>
Type Parameters
- T
Parameters
- _workflowName: string
- _runId: string
- operation: () => Promise<T>
Returns Promise<T>
- Defined in packages/flowsafe/src/do-runner/fenced-workflows-d1.ts:1331