def set_context(self, filename):
        """
        Provide filename context to airflow task handler.
        :param filename: filename in which the dag is located
        """
        local_loc = self._init_file(filename)
        self.handler = logging.FileHandler(local_loc)
        self.handler.setFormatter(self.formatter)
        self.handler.setLevel(self.level)

        if self._cur_date < datetime.today():
            self._symlink_latest_log_directory()
            self._cur_date = datetime.today()
def set_context(self, filename):
        """
        Provide filename context to airflow task handler.
        :param filename: filename in which the dag is located
        """
        local_loc = self._init_file(filename)
        self.handler = logging.FileHandler(local_loc)
        self.handler.setFormatter(self.formatter)
        self.handler.setLevel(self.level)

        if self._cur_date < datetime.today():
            self._symlink_latest_log_directory()
            self._cur_date = datetime.today()
def set_context ( self , filename ) : local_loc = self . _init_file ( filename ) self . handler = logging . FileHandler ( local_loc ) self . handler . setFormatter ( self . formatter ) self . handler . setLevel ( self . level ) if self . _cur_date < datetime . today ( ) : self . _symlink_latest_log_directory ( ) self . _cur_date = datetime . today ( )
Provide filename context to airflow task handler.
        :param filename: filename in which the dag is located
Provide filename context to airflow task handler . : param filename : filename in which the dag is located