Skip to content

Commit c3c9bb9

Browse files
committed
WIP: Make WorkerExec::properties return self.properties
1 parent ffbed2d commit c3c9bb9

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

rust/cubestore/cubestore/src/queryplanner/planning.rs

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1749,7 +1749,7 @@ impl WorkerExec {
17491749
required_input_ordering: Option<LexRequirement>,
17501750
) -> WorkerExec {
17511751
// TODO upgrade DF: Use partitions_num parameter.
1752-
let partitions_num = 1; // TODO upgrade DF: No.
1752+
let partitions_num = 2; // TODO upgrade DF: No.
17531753
let properties = input.properties().clone().with_partitioning(Partitioning::UnknownPartitioning(partitions_num));
17541754
WorkerExec {
17551755
input,
@@ -1805,8 +1805,7 @@ impl ExecutionPlan for WorkerExec {
18051805
}
18061806

18071807
fn properties(&self) -> &PlanProperties {
1808-
// TODO upgrade DF: No.
1809-
self.input.properties()
1808+
&self.properties
18101809
}
18111810

18121811
fn required_input_distribution(&self) -> Vec<Distribution> {

0 commit comments

Comments
 (0)