@@ -88,10 +88,10 @@ describe('HfDatasetLogger', () => {
88
88
} ) ;
89
89
90
90
it ( 'should drop oldest logs when buffer exceeds maximum size' , async ( ) => {
91
- logger = createTestLogger ( { batchSize : 2000 , flushInterval : 60000 } ) ; // Prevent auto-flush
91
+ logger = createTestLogger ( { batchSize : 20000 , flushInterval : 60000 } ) ; // Prevent auto-flush
92
92
93
- // Add logs to exceed buffer capacity (maxBufferSize = 1000 )
94
- for ( let i = 0 ; i < 1002 ; i ++ ) {
93
+ // Add logs to exceed buffer capacity (maxBufferSize = 10000 )
94
+ for ( let i = 0 ; i < 10002 ; i ++ ) {
95
95
logger . processLog ( {
96
96
level : 30 ,
97
97
time : Date . now ( ) ,
@@ -102,8 +102,8 @@ describe('HfDatasetLogger', () => {
102
102
// Wait a bit to ensure all logs are processed
103
103
await new Promise ( ( resolve ) => setTimeout ( resolve , 10 ) ) ;
104
104
105
- // Buffer should be at max size (1000 ), not 1002
106
- expect ( logger . getStatus ( ) . bufferSize ) . toBe ( 1000 ) ;
105
+ // Buffer should be at max size (10000 ), not 10002
106
+ expect ( logger . getStatus ( ) . bufferSize ) . toBe ( 10000 ) ;
107
107
} ) ;
108
108
} ) ;
109
109
@@ -254,7 +254,7 @@ describe('HfDatasetLogger', () => {
254
254
255
255
const status = logger . getStatus ( ) ;
256
256
expect ( status ) . toBeDefined ( ) ;
257
- expect ( status . bufferSize ) . toBeLessThanOrEqual ( 1000 ) ; // Should respect max buffer size
257
+ expect ( status . bufferSize ) . toBeLessThanOrEqual ( 10000 ) ; // Should respect max buffer size
258
258
} ) ;
259
259
} ) ;
260
260
@@ -322,7 +322,7 @@ describe('HfDatasetLogger', () => {
322
322
323
323
const status = logger . getStatus ( ) ;
324
324
// Should not accumulate unlimited logs
325
- expect ( status . bufferSize ) . toBeLessThanOrEqual ( 1000 ) ;
325
+ expect ( status . bufferSize ) . toBeLessThanOrEqual ( 10000 ) ;
326
326
} ) ;
327
327
328
328
it ( 'should handle large log messages efficiently' , ( ) => {
0 commit comments