(self, from_state, to_state)
| 518 | operation_adversary=self.adversary.name) |
| 519 | |
| 520 | def _emit_state_change_event(self, from_state, to_state): |
| 521 | event_svc = BaseService.get_service('event_svc') |
| 522 | |
| 523 | task = asyncio.get_event_loop().create_task( |
| 524 | event_svc.fire_event( |
| 525 | exchange=Operation.EVENT_EXCHANGE, |
| 526 | queue=Operation.EVENT_QUEUE_STATE_CHANGED, |
| 527 | op=self.id, |
| 528 | from_state=from_state, |
| 529 | to_state=to_state |
| 530 | ) |
| 531 | ) |
| 532 | |
| 533 | return task |
| 534 | |
| 535 | @staticmethod |
| 536 | def _get_ability_metadata_for_event_log(ability): |