Skip to content

Commit

Permalink
Avoiding creating pipeline when no shard
Browse files Browse the repository at this point in the history
  • Loading branch information
fulmicoton committed Jan 15, 2024
1 parent 48915f9 commit 0390ba1
Showing 1 changed file with 3 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -197,6 +197,9 @@ fn convert_scheduling_solution_to_physical_plan_single_node_single_source(
mut previous_tasks: &[&IndexingTask],
source: &SourceToSchedule,
) -> Vec<IndexingTask> {
if remaining_num_shards_to_schedule_on_node == 0 {
return Vec::new();
}
match &source.source_type {
SourceToScheduleType::Sharded {
shard_ids,
Expand Down

0 comments on commit 0390ba1

Please sign in to comment.