Function execWithLockConnValues

packages/cluster/src/SqlRunnerStorage.ts:262–271

(
    effect: Statement.Statement<A>
  )

    )
  }
  const execWithLockConnValues = <A>(
    effect: Statement.Statement<A>
  ): Effect.Effect<ReadonlyArray<ReadonlyArray<any>>, SqlError> => {
    if (!lockConn) return effect.values
    const [query, params] = effect.compile()
    return lockConn.await.pipe(
      Effect.flatMap(([conn]) => conn.executeValues(query, params)),
      Effect.onError(() => lockConn.unsafeRebuild())
    )
  }

  const acquireLock = sql.onDialectOrElse({
    pg: () => {