Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- diff --git a/SkyNET/Exo.py b/SkyNET/Exo.py
- index 8bef615..9002324 100644
- --- a/SkyNET/Exo.py
- +++ b/SkyNET/Exo.py
- @@ -28,6 +28,14 @@ class ExoParticipant(Participant):
- def __init__(self, exo=None, *args, **kwargs):
- super(ExoParticipant,self).__init__(*args, **kwargs)
- self.exo=exo
- + if "handle_reply_to_engine" in dir(self.exo.handler):
- + def func(wi): self.handle_reply_to_engine(wi)
- + self.exo.reply_to_engine = func
- +
- + def handle_reply_to_engine(wi):
- + self.workitem = wi
- + super(ExoParticipant,self).reply_to_engine()
- def consume(self):
- self.exo.handler.handle_wi(self.workitem)
Add Comment
Please, Sign In to add comment