"""Allows to redirect stdout and stderr to logger"""
    encoding: None = None
    def __init__(self, logger, level):
        """
        :param log: The log level method to write to, ie. log.debug, log.warning
        :return:
        """
        self.logger = logger
        self.level = level
        self._buffer = ""
    def close(self):
        """
        Provide close method, for compatibility with the io.IOBase interface.
        This is a no-op method.
        """
    @property
    def closed(self):
        """
        Returns False to indicate that the stream is not closed, as it will be
        open for the duration of Airflow's lifecycle.
        For compatibility with the io.IOBase interface.
        """
        return False
    def _propagate_log(self, message):