Skip to content

Commit

Permalink
Fix no_bars passing
Browse files Browse the repository at this point in the history
  • Loading branch information
munrojm committed Sep 26, 2022
1 parent 187df6e commit a1e98a2
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions src/maggma/cli/distributed.py
Original file line number Diff line number Diff line change
Expand Up @@ -210,7 +210,7 @@ def handle_dead_workers(workers, socket):
)


async def worker(url: str, port: int, num_processes: int):
async def worker(url: str, port: int, num_processes: int, no_bars: bool):
"""
Simple distributed worker that connects to a manager asks for work and deploys
using multiprocessing
Expand Down Expand Up @@ -240,7 +240,7 @@ async def worker(url: str, port: int, num_processes: int):
# We have a valid builder
work = json.loads(message)
builder = MontyDecoder().process_decoded(work)
await multi(builder, num_processes, socket=socket)
await multi(builder, num_processes, socket=socket, no_bars=no_bars)
elif message == "EXIT":
# End the worker
running = False
Expand Down

0 comments on commit a1e98a2

Please sign in to comment.