undo ray runner change

Eventual-Inc · Oct 17, 2024 · ded9d6f · ded9d6f
1 parent 3c69ea1
commit ded9d6f
Showing 1 changed file with 1 addition and 5 deletions.
diff --git a/daft/runners/ray_runner.py b/daft/runners/ray_runner.py
@@ -923,11 +923,7 @@ def _build_partitions_on_actor_pool(
 
 @ray.remote
 class DaftRayActor:
-    def __init__(
-        self,
-        daft_execution_config: PyDaftExecutionConfig,
-        uninitialized_projection: ExpressionsProjection,
-    ):
+    def __init__(self, daft_execution_config: PyDaftExecutionConfig, uninitialized_projection: ExpressionsProjection):
         self.daft_execution_config = daft_execution_config
         partial_stateful_udfs = {
             name: psu