Return logging details for this task
(self, dct=None)
| 385 | self.task_spec._on_trigger(self, *args) |
| 386 | |
| 387 | def collect_log_extras(self, dct=None): |
| 388 | """Return logging details for this task""" |
| 389 | extra = { |
| 390 | 'workflow_spec': self.workflow.spec.name, |
| 391 | 'task_spec': self.task_spec.name, |
| 392 | 'task_id': self.id, |
| 393 | 'task_type': self.task_spec.__class__.__name__, |
| 394 | 'state': TaskState.get_name(self._state), |
| 395 | 'last_state_change': self.last_state_change, |
| 396 | 'elapsed': 0, |
| 397 | 'parent': None if self.parent is None else self.parent.id, |
| 398 | } |
| 399 | if dct is not None: |
| 400 | extra.update(dct) |
| 401 | if logger.level < 20: |
| 402 | extra.update({ |
| 403 | 'data': self.data if logger.level < 20 else None, |
| 404 | 'internal_data': self.internal_data if logger.level < 20 else None, |
| 405 | }) |
| 406 | return extra |
| 407 | |
| 408 | def __iter__(self): |
| 409 | return TaskIterator(self) |
no test coverage detected