(
ref: ConnectionRef,
)
| 2095 | // ------------------------------------------------------------------ |
| 2096 | |
| 2097 | const findConnectionRow = ( |
| 2098 | ref: ConnectionRef, |
| 2099 | ): Effect.Effect<ConnectionRow | null, StorageFailure> => |
| 2100 | core.findFirst("connection", { |
| 2101 | where: (b: AnyCb) => |
| 2102 | b.and( |
| 2103 | byOwner(ref.owner)(b), |
| 2104 | b("integration", "=", String(ref.integration)), |
| 2105 | b("name", "=", String(ref.name)), |
| 2106 | ), |
| 2107 | }); |
| 2108 | |
| 2109 | // Key for the shared in-flight refresh gate (`refreshInFlight`, bound at |
| 2110 | // the top of `createExecutor`). The tenant leads because the gate spans |
no test coverage detected