@persistent-ai/fireflow-executor / server / loadFlow

Function: loadFlow()

loadFlow(coord, userId): Promise<Flow | null>

Defined in: packages/fireflow-executor/server/stores/flow-store.ts:40

Load + hydrate a flow from VFS at its pinned coordinate (RFC 057).

Replaces the old Postgres flows-table load: the flow definition is read from lakeFS AT the immutable commitHash (replay-deterministic), then deserialized and migrated to schema v2. No DBOS step wraps this — flow data is large and must not be checkpointed into DBOS system logs; the commit pin already makes the read stable across replays.

Parameters

coord

FlowCoordinate

the execution's pinned VFS coordinate (the read uses commitHash, never the moving ref).

userId

string

the workspace-owner identity authorized to read (the execution's ownerId; access was already authorized at create()).

Returns

Promise<Flow | null>

the hydrated flow, or null on any read/permission/parse failure (the caller surfaces a "not found" error; details are logged here).