Function fireClock

packages/infra/src/WorkflowEngineSqlite.ts:582–599

(
    executionId: string,
    name: string,
    deferredName: string
  )

  // --- Clock firing -----------------------------------------------------

  const fireClock = (
    executionId: string,
    name: string,
    deferredName: string
  ): Effect.Effect<void> =>
    Effect
      .gen(function*() {
        const encoded = yield* encodeDeferredExit(Exit.void)
        const inserted = yield* sql
          .withTransaction(Effect.gen(function*() {
            const got = yield* createDeferred(executionId, deferredName, encoded)
            yield* deleteClock(executionId, name)
            return got
          }))
          .pipe(Effect.orDie)
        if (inserted) yield* driveById(executionId)
      })
      .pipe(annotate("clockFire", executionId))

  // --- Encoded engine ---------------------------------------------------