Function createDeferred

packages/infra/src/WorkflowEngineSqlite.ts:394–406

(
    executionId: string,
    name: string,
    encoded: string
  )

      )

  const createDeferred = (
    executionId: string,
    name: string,
    encoded: string
  ): Effect.Effect<boolean> =>
    exec(
      `INSERT INTO "${deferredTable}" (execution_id, name, exit)
       VALUES (?, ?, ?)
       ON CONFLICT DO NOTHING
       RETURNING execution_id`,
      [executionId, name, encoded]
    )
      .pipe(Effect.map((rows) => (rows as ReadonlyArray<unknown>).length > 0))

  const readDeferred = (
    executionId: string,