Logging to a package's logger

myfuncs.py

import logging
import dask

logger = logging.getLogger(__name__)

@dask.delayed
def times(arg, mult):
    logger.info(f"Multiplying: {arg} * {mult}")
    return arg * mult

myscript.py

import logging
from dask.distributed import LocalCluster, Client

from myfuncs import times

if __name__ == "__main__":
    logger = logging.getLogger("myfuncs")
    handler = logging.StreamHandler()
    fmt = "{levelname}:{asctime}:{name}:{lineno}: {message}"
    formatter = logging.Formatter(fmt, style="{")
    handler.setFormatter(formatter)
    logger.addHandler(handler)

    # set the level only _after_ you have instantiated the logger
    # doing it earlier will is simply ignored
    logger.setLevel(logging.INFO)

    logger.info("Starting")
    cluster = LocalCluster(n_workers=2)
    client = Client(cluster)
    dld_times = times(6, 7)
    logger.info(f"Result: {dld_times.compute()}")