(
ref: ConnectionRef,
)
| 2180 | // ------------------------------------------------------------------ |
| 2181 | |
| 2182 | const findConnectionRow = ( |
| 2183 | ref: ConnectionRef, |
| 2184 | ): Effect.Effect<ConnectionRow | null, StorageFailure> => |
| 2185 | core.findFirst("connection", { |
| 2186 | where: (b: AnyCb) => |
| 2187 | b.and( |
| 2188 | byOwner(ref.owner)(b), |
| 2189 | b("integration", "=", String(ref.integration)), |
| 2190 | b("name", "=", String(ref.name)), |
| 2191 | ), |
| 2192 | }); |
| 2193 | |
| 2194 | // Key for the shared in-flight refresh gate (`refreshInFlight`, bound at |
| 2195 | // the top of `createExecutor`). The tenant leads because the gate spans |
no test coverage detected