Hello all, It has been pointed out to me by Chad, and also by others, that my logging changes have caused logs to start getting lost.
It seems that by never logging on the root logger, initialization for a root handler is skipped; and that's what causes the failures. I will work on a fix for this. I am thinking of providing a very simple apache_beam.utils.get_logger function that does something like this: def get_logger(name): logging.basicConfig() return logging.getLogger(name) And specific paths that need special handling of the logs should override this config by adding their own handlers (e.g. sdk_worker, fn_api_runner, etc). I hope I can have a fix for this by tomorrow. Best -P.