|
|
@@ -261,16 +261,16 @@ describe('continuable activation capacity', () => {
|
|
|
}
|
|
|
})
|
|
|
|
|
|
- it('defaults to sixteen live children and reuses capacity after settlement', async () => {
|
|
|
+ it('defaults to eight live children and reuses capacity after settlement', async () => {
|
|
|
const release = Promise.withResolvers<undefined>()
|
|
|
const adapter = new GatedAdapter([
|
|
|
- ...Array.from({ length: 16 }, () => ({ chunks: textResponse('done'), gate: release.promise })),
|
|
|
+ ...Array.from({ length: 8 }, () => ({ chunks: textResponse('done'), gate: release.promise })),
|
|
|
{ chunks: textResponse('replacement') },
|
|
|
])
|
|
|
const { ctx, parent } = await setupWith(adapter)
|
|
|
parkParent(ctx, parent)
|
|
|
try {
|
|
|
- const started = await Promise.all(Array.from({ length: 16 }, () => ctx.subagents.startContinuable(startSpec(parent))))
|
|
|
+ const started = await Promise.all(Array.from({ length: 8 }, () => ctx.subagents.startContinuable(startSpec(parent))))
|
|
|
await expect(ctx.subagents.startContinuable(startSpec(parent))).rejects.toMatchObject({ code: 'ACTIVATION_LIMIT_REACHED' })
|
|
|
release.resolve(undefined)
|
|
|
await Promise.all(started.map(child => waitNoActivation(ctx, child.childId)))
|