(
ref: ConnectionRef,
)
| 1966 | // ------------------------------------------------------------------ |
| 1967 | |
| 1968 | const findConnectionRow = ( |
| 1969 | ref: ConnectionRef, |
| 1970 | ): Effect.Effect<ConnectionRow | null, StorageFailure> => |
| 1971 | core.findFirst("connection", { |
| 1972 | where: (b: AnyCb) => |
| 1973 | b.and( |
| 1974 | byOwner(ref.owner)(b), |
| 1975 | b("integration", "=", String(ref.integration)), |
| 1976 | b("name", "=", String(ref.name)), |
| 1977 | ), |
| 1978 | }); |
| 1979 | |
| 1980 | // Key for the shared in-flight refresh gate (`refreshInFlight`, bound at |
| 1981 | // the top of `createExecutor`). The tenant leads because the gate spans |
no test coverage detected