Skip to content

Commit f11a418

Browse files
committed
misc cleanup
1 parent 0c66f69 commit f11a418

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

src/distributed_physical_optimizer_rule.rs

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -84,8 +84,7 @@ impl DistributedPhysicalOptimizerRule {
8484
)?);
8585

8686
let maybe_isolated_plan =
87-
if can_be_divided(&plan)? && self.partitions_per_task.is_some() {
88-
let ppt = self.partitions_per_task.unwrap();
87+
if let Some(ppt) = self.partitions_per_task && can_be_divided(&plan)? {
8988
let isolated = Arc::new(PartitionIsolatorExec::new(child, ppt));
9089
plan.with_new_children(vec![isolated])?
9190
} else {

0 commit comments

Comments
 (0)