def errLog(x): """ Logs x to celery INFO. Used as a callback in sh piping to manually print otherwise swallowed error logs. """ logger = get_task_logger(__name__) logger.info(x)