Skip to content

Commit

Permalink
Fix SpawnPipeline field after rebase
Browse files Browse the repository at this point in the history
  • Loading branch information
rdettai committed Dec 11, 2023
1 parent ff74f52 commit 1dfd035
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions quickwit/quickwit-lambda/src/indexer/ingest.rs
Original file line number Diff line number Diff line change
Expand Up @@ -46,7 +46,7 @@ use quickwit_ingest::IngesterPool;
use quickwit_metastore::CreateIndexRequestExt;
use quickwit_proto::indexing::CpuCapacity;
use quickwit_proto::metastore::{CreateIndexRequest, MetastoreError, MetastoreService};
use quickwit_proto::types::NodeId;
use quickwit_proto::types::{NodeId, PipelineUid};
use quickwit_storage::StorageResolver;
use tracing::{debug, info, instrument};

Expand Down Expand Up @@ -210,7 +210,7 @@ pub async fn ingest(args: IngestArgs) -> anyhow::Result<IndexingStatistics> {
.ask_for_res(SpawnPipeline {
index_id: INDEX_ID.clone(),
source_config,
pipeline_ord: 0,
pipeline_uid: PipelineUid::default(),
})
.await?;
let merge_pipeline_handle = indexing_server_mailbox
Expand Down

0 comments on commit 1dfd035

Please sign in to comment.