remove unused code

Eventual-Inc · Jan 15, 2025 · 5d82992 · 5d82992
1 parent d5766af
commit 5d82992
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 5 deletions.
diff --git a/daft/daft/__init__.pyi b/daft/daft/__init__.pyi
@@ -1689,10 +1689,6 @@ class LogicalPlanBuilder:
 
 class NativeExecutor:
     def __init__(self) -> None: ...
-    # @staticmethod
-    # def from_logical_plan_builder(
-    #     logical_plan_builder: LogicalPlanBuilder,
-    # ) -> NativeExecutor: ...
     def run(
         self, psets: dict[str, list[PartitionT]], cfg: PyDaftExecutionConfig, results_buffer_size: int | None
     ) -> Iterator[PyMicroPartition]: ...

diff --git a/daft/runners/pyrunner.py b/daft/runners/pyrunner.py
@@ -380,8 +380,9 @@ def run_iter(
             if daft_execution_config.enable_native_executor:
                 logger.info("Using native executor")
 
-                executor = NativeExecutor.from_logical_plan_builder(builder)
+                executor = NativeExecutor()
                 results_gen = executor.run(
+                    builder,
                     {k: v.values() for k, v in self._part_set_cache.get_all_partition_sets().items()},
                     daft_execution_config,
                     results_buffer_size,