Skip to content

Commit

Permalink
remove dead code
Browse files Browse the repository at this point in the history
  • Loading branch information
samster25 committed Nov 15, 2023
1 parent e689316 commit 15fdb67
Showing 1 changed file with 0 additions and 2 deletions.
2 changes: 0 additions & 2 deletions daft/runners/pyrunner.py
Original file line number Diff line number Diff line change
Expand Up @@ -159,8 +159,6 @@ def _physical_plan_to_partitions(self, plan: physical_plan.MaterializedPhysicalP
future_to_task: dict[futures.Future, str] = dict()

pbars = dict()
# tqdm.set_lock(TRLock())
# initializer=tqdm.set_lock, initargs=(tqdm.get_lock(),)
with futures.ThreadPoolExecutor() as thread_pool:
try:
next_step = next(plan)
Expand Down

0 comments on commit 15fdb67

Please sign in to comment.