(
ref: ConnectionRef,
)
| 2229 | // ------------------------------------------------------------------ |
| 2230 | |
| 2231 | const findConnectionRow = ( |
| 2232 | ref: ConnectionRef, |
| 2233 | ): Effect.Effect<ConnectionRow | null, StorageFailure> => |
| 2234 | core.findFirst("connection", { |
| 2235 | where: (b: AnyCb) => |
| 2236 | b.and( |
| 2237 | byOwner(ref.owner)(b), |
| 2238 | b("integration", "=", String(ref.integration)), |
| 2239 | b("name", "=", String(ref.name)), |
| 2240 | ), |
| 2241 | }); |
| 2242 | |
| 2243 | // Key for the shared in-flight refresh gate (`refreshInFlight`, bound at |
| 2244 | // the top of `createExecutor`). The tenant leads because the gate spans |
no test coverage detected