Function fireClock

packages/infra/src/WorkflowEngineCosmos.ts:455–468

(doc: ClockDoc)

  // Persist deferred completion (first-writer-wins via createIfMissing),
  // resume the workflow, then clean up the clock doc.
  const fireClock = (doc: ClockDoc): Effect.Effect<void> =>
    Effect.gen(function*() {
      const created = yield* createIfMissing<DeferredDoc>({
        id: deferredKey(doc.deferredName),
        _partitionKey: doc._partitionKey,
        type: "deferred",
        exit: yield* encodeDeferredExit(Exit.void)
      })
        .pipe(annotate("clockFire", doc._partitionKey))
      if (created) yield* driveById(doc._partitionKey)
      yield* Effect.promise(() => container.item(doc.id, doc._partitionKey).delete()).pipe(
        Effect.catchCause(() => Effect.void)
      )
    })

  // Persist `interrupted: true`, retrying on OCC. A suspending driver's
  // onComplete (or a heartbeat renewal) can win the etag race; silently