diff --git a/dev-packages/node-core-integration-tests/suites/sessions/errored-session-aggregate/test.ts b/dev-packages/node-core-integration-tests/suites/sessions/errored-session-aggregate/test.ts index ba8110a62675..4ff4dea6d5cd 100644 --- a/dev-packages/node-core-integration-tests/suites/sessions/errored-session-aggregate/test.ts +++ b/dev-packages/node-core-integration-tests/suites/sessions/errored-session-aggregate/test.ts @@ -10,14 +10,17 @@ test('should aggregate successful, crashed and erroneous sessions', async () => .ignore('transaction', 'event') .unignore('sessions') .expect({ - sessions: { - aggregates: [ - { - started: expect.any(String), - exited: 2, - errored: 1, - }, - ], + sessions: agg => { + // Sessions are bucketed by minute; tolerate splits across a minute boundary by summing. + const totals = agg.aggregates.reduce( + (acc, b) => ({ + exited: acc.exited + (b.exited ?? 0), + errored: acc.errored + (b.errored ?? 0), + crashed: acc.crashed + (b.crashed ?? 0), + }), + { exited: 0, errored: 0, crashed: 0 }, + ); + expect(totals).toEqual({ exited: 2, errored: 1, crashed: 0 }); }, }) .start(); diff --git a/dev-packages/node-core-integration-tests/suites/sessions/exited-session-aggregate/test.ts b/dev-packages/node-core-integration-tests/suites/sessions/exited-session-aggregate/test.ts index 228ee9a98643..152861e87765 100644 --- a/dev-packages/node-core-integration-tests/suites/sessions/exited-session-aggregate/test.ts +++ b/dev-packages/node-core-integration-tests/suites/sessions/exited-session-aggregate/test.ts @@ -10,13 +10,17 @@ test('should aggregate successful sessions', async () => { .ignore('transaction', 'event') .unignore('sessions') .expect({ - sessions: { - aggregates: [ - { - started: expect.any(String), - exited: 3, - }, - ], + sessions: agg => { + // Sessions are bucketed by minute; tolerate splits across a minute boundary by summing. + const totals = agg.aggregates.reduce( + (acc, b) => ({ + exited: acc.exited + (b.exited ?? 0), + errored: acc.errored + (b.errored ?? 0), + crashed: acc.crashed + (b.crashed ?? 0), + }), + { exited: 0, errored: 0, crashed: 0 }, + ); + expect(totals).toEqual({ exited: 3, errored: 0, crashed: 0 }); }, }) .start(); diff --git a/dev-packages/node-integration-tests/suites/sessions/crashed-session-aggregate/test.ts b/dev-packages/node-integration-tests/suites/sessions/crashed-session-aggregate/test.ts index 712eeffcdeb3..ad8166e3163c 100644 --- a/dev-packages/node-integration-tests/suites/sessions/crashed-session-aggregate/test.ts +++ b/dev-packages/node-integration-tests/suites/sessions/crashed-session-aggregate/test.ts @@ -10,14 +10,17 @@ test('should aggregate successful and crashed sessions', async () => { .ignore('transaction', 'event') .unignore('sessions') .expect({ - sessions: { - aggregates: [ - { - started: expect.any(String), - exited: 2, - crashed: 1, - }, - ], + sessions: agg => { + // Sessions are bucketed by minute; tolerate splits across a minute boundary by summing. + const totals = agg.aggregates.reduce( + (acc, b) => ({ + exited: acc.exited + (b.exited ?? 0), + errored: acc.errored + (b.errored ?? 0), + crashed: acc.crashed + (b.crashed ?? 0), + }), + { exited: 0, errored: 0, crashed: 0 }, + ); + expect(totals).toEqual({ exited: 2, errored: 0, crashed: 1 }); }, }) .start(); diff --git a/dev-packages/node-integration-tests/suites/sessions/errored-session-aggregate/test.ts b/dev-packages/node-integration-tests/suites/sessions/errored-session-aggregate/test.ts index 4f35e6259697..d2c83f5d30fa 100644 --- a/dev-packages/node-integration-tests/suites/sessions/errored-session-aggregate/test.ts +++ b/dev-packages/node-integration-tests/suites/sessions/errored-session-aggregate/test.ts @@ -10,15 +10,17 @@ test('should aggregate successful, crashed and erroneous sessions', async () => .ignore('transaction', 'event') .unignore('sessions') .expect({ - sessions: { - aggregates: [ - { - started: expect.any(String), - exited: 1, - crashed: 1, - errored: 1, - }, - ], + sessions: agg => { + // Sessions are bucketed by minute; tolerate splits across a minute boundary by summing. + const totals = agg.aggregates.reduce( + (acc, b) => ({ + exited: acc.exited + (b.exited ?? 0), + errored: acc.errored + (b.errored ?? 0), + crashed: acc.crashed + (b.crashed ?? 0), + }), + { exited: 0, errored: 0, crashed: 0 }, + ); + expect(totals).toEqual({ exited: 1, errored: 1, crashed: 1 }); }, }) .start(); diff --git a/dev-packages/node-integration-tests/suites/sessions/exited-session-aggregate/test.ts b/dev-packages/node-integration-tests/suites/sessions/exited-session-aggregate/test.ts index 228ee9a98643..152861e87765 100644 --- a/dev-packages/node-integration-tests/suites/sessions/exited-session-aggregate/test.ts +++ b/dev-packages/node-integration-tests/suites/sessions/exited-session-aggregate/test.ts @@ -10,13 +10,17 @@ test('should aggregate successful sessions', async () => { .ignore('transaction', 'event') .unignore('sessions') .expect({ - sessions: { - aggregates: [ - { - started: expect.any(String), - exited: 3, - }, - ], + sessions: agg => { + // Sessions are bucketed by minute; tolerate splits across a minute boundary by summing. + const totals = agg.aggregates.reduce( + (acc, b) => ({ + exited: acc.exited + (b.exited ?? 0), + errored: acc.errored + (b.errored ?? 0), + crashed: acc.crashed + (b.crashed ?? 0), + }), + { exited: 0, errored: 0, crashed: 0 }, + ); + expect(totals).toEqual({ exited: 3, errored: 0, crashed: 0 }); }, }) .start();