Total Complexity | 1 |
Total Lines | 19 |
Duplicated Lines | 0 % |
Changes | 1 | ||
Bugs | 0 | Features | 0 |
1 | """ |
||
10 | class JobFinishedMessageEventHandler: |
||
11 | """ |
||
12 | An event handler for a ScheduleDefinitionMessage received events. |
||
13 | """ |
||
14 | |||
15 | # ------------------------------------------------------------------------------------------------------------------ |
||
16 | @staticmethod |
||
17 | def handle(_event, message, controller): |
||
18 | """ |
||
19 | Handles a JobFinishedMessage received event. |
||
20 | |||
21 | :param * _event: Not used. |
||
22 | :param enarksh.controller.message.JobFinishedMessage.JobFinishedMessage message: The message. |
||
23 | :param enarksh.controller.Controller.Controller controller: The controller. |
||
24 | """ |
||
25 | del _event |
||
26 | |||
27 | schedule = controller.get_schedule_by_sch_id(message.sch_id) |
||
28 | schedule.event_node_stop(message.rnd_id, message.exit_status) |
||
29 | |||
31 |