Function createExec

packages/infra/src/WorkflowEngineSqlite.ts:322–343

(initial: ExecState)

      .pipe(annotate("replaceExec", state.executionId))

  const createExec = (initial: ExecState): Effect.Effect<boolean> =>
    exec(
      `INSERT INTO "${execTable}"
         (execution_id, workflow_name, payload, parent, status, suspended, interrupted, etag)
       VALUES (?, ?, ?, ?, ?, ?, ?, ?)
       ON CONFLICT DO NOTHING
       RETURNING execution_id`,
      [
        initial.executionId,
        initial.workflowName,
        initial.payload,
        initial.parent ?? null,
        initial.status,
        initial.suspended ? 1 : 0,
        initial.interrupted ? 1 : 0,
        initial.etag
      ]
    )
      .pipe(
        Effect.map((rows) => (rows as ReadonlyArray<unknown>).length > 0),
        annotate("createExec", initial.executionId)
      )

  // First-writer-wins persistence of an activity result; returns true if this
  // call won, false if another writer beat us to the (exec, name, attempt) row.