Function readLock

packages/infra/src/ClusterCosmos.ts:868–873

(shardId: string)

    .pipe(Effect.catchIf(isConflict, () => Effect.void), Effect.orDie)

  const readLock = (shardId: string) =>
    Effect.tryPromise(() => container.item(lockDocId(shardId), "lock").read<LockDoc>()).pipe(
      Effect.tap(annotateItem),
      Effect.map((resp) => Option.fromNullishOr(resp.resource)),
      Effect.catchIf(isNotFound, () => Effect.succeed(Option.none()))
    )

  const writeLock = (doc: LockDoc) =>
    Effect