Conditions | 1 |
Total Lines | 16 |
Lines | 0 |
Ratio | 0 % |
Tests | 0 |
CRAP Score | 2 |
Changes | 1 | ||
Bugs | 0 | Features | 0 |
1 | """ |
||
18 | @staticmethod |
||
19 | def handle(_event, message, spawner): |
||
20 | """ |
||
21 | Handles a SpawnJobMessage received event. |
||
22 | |||
23 | :param * _event: Not used. |
||
24 | :param enarksh.spawner.message.SpawnJobMessage.SpawnJobMessage message: The message. |
||
25 | :param enarksh.spawner.Spawner.Spawner spawner: The spawner. |
||
26 | """ |
||
27 | del _event |
||
28 | |||
29 | job_handler = JobHandler(message.sch_id, message.rnd_id, message.user_name, message.args) |
||
30 | job_handler.start_job() |
||
31 | job_handler.final_event.register_listener(JobFinallyDoneEventHandler.handle, (spawner, job_handler.pid)) |
||
32 | |||
33 | spawner.add_job_handler(job_handler) |
||
34 | |||
36 |