Skip to content

Commit 6673e31

Browse files
committed
misc cleanup
1 parent 28d4203 commit 6673e31

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)