Skip to content

Commit d82b649

Browse files
committed
Use reset_source_checkpoint instead of delete_source
1 parent 624dfed commit d82b649

File tree

1 file changed

+3
-3
lines changed
  • quickwit/quickwit-lambda/src/indexer/ingest

1 file changed

+3
-3
lines changed

quickwit/quickwit-lambda/src/indexer/ingest/helpers.rs

+3-3
Original file line numberDiff line numberDiff line change
@@ -48,8 +48,8 @@ use quickwit_metastore::{
4848
};
4949
use quickwit_proto::indexing::CpuCapacity;
5050
use quickwit_proto::metastore::{
51-
CreateIndexRequest, DeleteSourceRequest, IndexMetadataRequest, MetastoreError,
52-
MetastoreService, MetastoreServiceClient,
51+
CreateIndexRequest, IndexMetadataRequest, MetastoreError, MetastoreService,
52+
MetastoreServiceClient, ResetSourceCheckpointRequest,
5353
};
5454
use quickwit_proto::types::{NodeId, PipelineUid};
5555
use quickwit_search::SearchJobPlacer;
@@ -308,7 +308,7 @@ pub(super) async fn prune_lambda_source(
308308
"prune Lambda checkpoints"
309309
);
310310
metastore
311-
.delete_source(DeleteSourceRequest {
311+
.reset_source_checkpoint(ResetSourceCheckpointRequest {
312312
index_uid: Some(index_metadata.index_uid.clone()),
313313
source_id: LAMBDA_SOURCE_ID.to_owned(),
314314
})

0 commit comments

Comments
 (0)