Total Complexity | 1 |
Total Lines | 19 |
Duplicated Lines | 0 % |
Coverage | 0% |
Changes | 1 | ||
Bugs | 0 | Features | 0 |
1 | """ |
||
10 | class JobFinallyDoneEventHandler: |
||
11 | """ |
||
12 | The event handler for a job finally done event. |
||
13 | """ |
||
14 | |||
15 | @staticmethod |
||
16 | # ------------------------------------------------------------------------------------------------------------------ |
||
17 | def handle(_event, _event_data, listener_data): |
||
18 | """ |
||
19 | Handles a SpawnJobMessage received event. |
||
20 | |||
21 | :param * _event: Not used. |
||
22 | :param * _event_data: Not used. |
||
23 | :param (enarksh.spawner.Spawner.Spawner,int) listener_data: The spawner and the PID of the processes of the job. |
||
24 | """ |
||
25 | del _event, _event_data |
||
26 | |||
27 | spawner, pid = listener_data |
||
28 | spawner.remove_job_handler(pid) |
||
29 | |||
31 |