@@ -331,12 +331,10 @@ export class EmbeddingsChunkSearch extends Disposable implements IWorkspaceChunk
331
331
}
332
332
} ;
333
333
334
- this . _reindexDisposables . add ( this . _workspaceIndex . onDidCreateFiles ( async uris => {
334
+ this . _reindexDisposables . add ( this . _workspaceIndex . onDidCreateFiles ( async _uris => {
335
335
updateIndexState ( ) ;
336
- this . tryTriggerReindexing ( uris , new TelemetryCorrelationId ( 'EmbeddingsChunkSearch::onDidCreateFiles' ) ) ;
337
336
} ) ) ;
338
337
339
- this . _reindexDisposables . add ( this . _workspaceIndex . onDidChangeFiles ( uris => this . tryTriggerReindexing ( uris , new TelemetryCorrelationId ( 'EmbeddingsChunkSearch::onDidChangeFiles' ) ) ) ) ;
340
338
this . _reindexDisposables . add ( this . _workspaceIndex . onDidDeleteFiles ( uris => {
341
339
for ( const uri of uris ) {
342
340
this . _reindexRequests . get ( uri ) ?. dispose ( ) ;
@@ -388,18 +386,17 @@ export class EmbeddingsChunkSearch extends Disposable implements IWorkspaceChunk
388
386
}
389
387
}
390
388
391
- public tryTriggerReindexing ( uris : readonly URI [ ] , telemetryInfo : TelemetryCorrelationId , immediately = false ) : void {
389
+ public tryTriggerReindexing ( uris : readonly URI [ ] , telemetryInfo : TelemetryCorrelationId ) : void {
392
390
if ( this . _state === LocalEmbeddingsIndexStatus . TooManyFilesForAnyIndexing
393
391
|| this . _state === LocalEmbeddingsIndexStatus . TooManyFilesForAutomaticIndexing
394
392
) {
395
393
return ;
396
394
}
397
395
398
- const defaultDelay = this . _experimentationService . getTreatmentVariable < number > ( 'workspace.embeddingIndex.automaticReindexingDelay' ) ?? 60000 ;
399
396
for ( const uri of uris ) {
400
397
let delayer = this . _reindexRequests . get ( uri ) ;
401
398
if ( ! delayer ) {
402
- delayer = new Delayer < void > ( defaultDelay ) ;
399
+ delayer = new Delayer < void > ( 0 ) ;
403
400
this . _reindexRequests . set ( uri , delayer ) ;
404
401
}
405
402
@@ -413,7 +410,7 @@ export class EmbeddingsChunkSearch extends Disposable implements IWorkspaceChunk
413
410
}
414
411
415
412
return this . _embeddingsIndex . triggerIndexingOfFile ( uri , telemetryInfo . addCaller ( 'EmbeddingChunkSearch::tryTriggerReindexing' ) , this . _disposeCts . token ) ;
416
- } , immediately ? 0 : defaultDelay ) ;
413
+ } , 0 ) ;
417
414
}
418
415
}
419
416
}
0 commit comments