Skip to content

Commit

Permalink
improved comment
Browse files Browse the repository at this point in the history
  • Loading branch information
sanderegg committed May 16, 2023
1 parent 8cd64d4 commit e36b3ef
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -61,7 +61,7 @@ async def dask_setup(worker: distributed.Worker) -> None:
logging.root.setLevel(level=settings.LOG_LEVEL.value)
logger.setLevel(level=settings.LOG_LEVEL.value)
# NOTE: Dask attaches a StreamHandler to the logger in distributed
# stopping the propagation to prevent double logging
# removing them solves dual propagation of logs
for handler in logging.getLogger("distributed").handlers:
logging.getLogger("distributed").removeHandler(handler)
config_all_loggers(settings.DASK_LOG_FORMAT_LOCAL_DEV_ENABLED)
Expand Down

0 comments on commit e36b3ef

Please sign in to comment.