(ns: string)
| 179 | [`${tableName}::${ns}`, tableName] |
| 180 | ) |
| 181 | if ((existing as any[]).length > 0) return |
| 182 | yield* InfraLogger.logInfo(`Seeding data for ${name} (namespace: ${ns})`) |
| 183 | const items = yield* seed.pipe(Effect.provide(ctx), Effect.orDie) |
| 184 | const ne = toNonEmptyArray([...items]) |
| 185 | // Seed inserts are not concurrent; OCC here is a programming defect. |
| 186 | if (Option.isSome(ne)) { |
| 187 | yield* bulkSetInternal(ne.value, ns).pipe( |
| 188 | Effect.catchTag("OptimisticConcurrencyException", Effect.die) |
| 189 | ) |
| 190 | } |
| 191 | yield* exec( |
no test coverage detected
searching dependent graphs…