Function insertClock

packages/infra/src/WorkflowEngineSqlite.ts:423–437

(
    executionId: string,
    name: string,
    workflowName: string,
    deferredName: string,
    fireAt: number
  )

      )

  const insertClock = (
    executionId: string,
    name: string,
    workflowName: string,
    deferredName: string,
    fireAt: number
  ): Effect.Effect<boolean> =>
    exec(
      `INSERT INTO "${clockTable}" (execution_id, name, workflow_name, deferred_name, fire_at)
       VALUES (?, ?, ?, ?, ?)
       ON CONFLICT DO NOTHING
       RETURNING execution_id`,
      [executionId, name, workflowName, deferredName, fireAt]
    )
      .pipe(Effect.map((rows) => (rows as ReadonlyArray<unknown>).length > 0))

  const deleteClock = (executionId: string, name: string) =>
    exec(