Rename to fanout_by_hash

Eventual-Inc · Oct 28, 2024 · d36dd0c · d36dd0c
1 parent c2838a5
commit d36dd0c
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/daft/execution/rust_physical_plan_shim.py b/daft/execution/rust_physical_plan_shim.py
@@ -214,7 +214,7 @@ def sort(
     )
 
 
-def split_by_hash(
+def fanout_by_hash(
     input: physical_plan.InProgressPhysicalPlan[PartitionT],
     num_partitions: int,
     partition_by: list[PyExpr],

diff --git a/src/daft-scheduler/src/scheduler.rs b/src/daft-scheduler/src/scheduler.rs
@@ -500,7 +500,7 @@ fn physical_plan_to_partition_tasks(
                                 py,
                                 "daft.execution.rust_physical_plan_shim"
                             ))?
-                            .getattr(pyo3::intern!(py, "split_by_hash"))?
+                            .getattr(pyo3::intern!(py, "fanout_by_hash"))?
                             .call1((
                                 upstream_iter,
                                 hash_clustering_config.num_partitions,