add scheduler prints

Eventual-Inc · Feb 14, 2024 · bdbdc73 · bdbdc73
1 parent 7edb526
commit bdbdc73
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/daft/runners/ray_runner.py b/daft/runners/ray_runner.py
@@ -704,11 +704,13 @@ def __init__(
                 max_task_backlog=max_task_backlog,
                 use_ray_tqdm=True,
             )
+            print("==== using remote scheduler ====")
         else:
             self.scheduler = Scheduler(
                 max_task_backlog=max_task_backlog,
                 use_ray_tqdm=False,
             )
+            print("==== using local scheduler ====")
 
         print("==== Got to after scheduler creation ====")