(self, body, message)
| 37 | pass |
| 38 | |
| 39 | def process_task(self, body, message): |
| 40 | action = body.get('action') |
| 41 | task_id = body.get('task_id') |
| 42 | msg = body.get('msg') |
| 43 | if action == CeleryLoggerProducer.ACTION_TASK_LOG: |
| 44 | self.handle_task_log(task_id, msg, message) |
| 45 | elif action == CeleryLoggerProducer.ACTION_TASK_START: |
| 46 | self.handle_task_start(task_id, message) |
| 47 | elif action == CeleryLoggerProducer.ACTION_TASK_END: |
| 48 | self.handle_task_end(task_id, message) |
| 49 | |
| 50 | |
| 51 | class CeleryLoggerProducer: |
nothing calls this directly
no test coverage detected