Skip to content

Commit 56085c6

Browse files
committed
lambda by default
1 parent 888e853 commit 56085c6

3 files changed

Lines changed: 11 additions & 3 deletions

File tree

quickwit/quickwit-search/src/root.rs

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -752,6 +752,10 @@ pub(crate) async fn search_partial_hits_phase(
752752
&& searcher_context.searcher_config.lambda.is_some()
753753
{
754754
// Execute via Lambda
755+
info!(
756+
num_splits = split_metadatas.len(),
757+
"Starting lambda execution for leaf search"
758+
);
755759
execute_leaf_search_via_lambda(
756760
search_request,
757761
indexes_metas_for_leaf_search,
@@ -861,7 +865,11 @@ async fn execute_leaf_search_via_lambda(
861865
jobs_to_leaf_request(search_request, indexes_metas_for_leaf_search, batch_jobs);
862866
async move {
863867
let leaf_request = request?;
864-
lambda_invoker.invoke_leaf_search(leaf_request).await
868+
let response = lambda_invoker.invoke_leaf_search(leaf_request).await;
869+
if let Err(err) = &response {
870+
error!(error = %err, "Lambda invocation failed");
871+
}
872+
response
865873
}
866874
})
867875
.collect();

quickwit/quickwit-serve/src/elasticsearch_api/rest_handler.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -412,7 +412,7 @@ fn build_request_for_es_api(
412412
search_after,
413413
count_hits,
414414
ignore_missing_indexes,
415-
execution_mode: 0, // Default to gRPC
415+
execution_mode: 1, // Default to Lambda (RemoteFunction)
416416
},
417417
has_doc_id_field,
418418
))

quickwit/quickwit-serve/src/search_api/rest_handler.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -265,7 +265,7 @@ pub fn search_request_from_api_request(
265265
search_after: None,
266266
count_hits: search_request.count_all.into(),
267267
ignore_missing_indexes: false,
268-
execution_mode: 0, // Default to gRPC
268+
execution_mode: 1, // Default to Lambda (RemoteFunction)
269269
};
270270
Ok(search_request)
271271
}

0 commit comments

Comments
 (0)