(self, task_id)
| 218 | self.thread_id_fd_mapper[thread_id] = f |
| 219 | |
| 220 | def handle_task_end(self, task_id): |
| 221 | maxkb_logger.debug('handle_task_end') |
| 222 | ident_id = self.task_id_thread_id_mapper.get(task_id, '') |
| 223 | f = self.thread_id_fd_mapper.pop(ident_id, None) |
| 224 | if f and not f.closed: |
| 225 | f.write(CELERY_LOG_MAGIC_MARK) |
| 226 | f.close() |
| 227 | self.task_id_thread_id_mapper.pop(task_id, None) |