We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 3c1ff7f commit 7e0c775Copy full SHA for 7e0c775
src/planning.rs
@@ -451,6 +451,10 @@ pub async fn distribute_stages(
451
.collect();
452
453
for attempt in 0..3 {
454
+ if workers.is_empty() {
455
+ return Err(anyhow!("No workers available to distribute stages").into());
456
+ }
457
+
458
// all stages to workers
459
let (task_datas, final_addrs) =
460
assign_to_workers(query_id, &stages, workers.values().collect())?;
0 commit comments