Method flush

apps/ops/celery/logger.py:208–210

(self)

        f.flush()

    def flush(self):
        for f in self.thread_id_fd_mapper.values():
            f.flush()

    def handle_task_start(self, task_id):
        maxkb_logger.debug('handle_task_start')