Commit ab158e86 authored by Jim Fulton's avatar Jim Fulton

Handle setting results on Delays who'd protocol were never set

Because races
parent 9ef630e2
...@@ -165,12 +165,14 @@ class Delay(object): ...@@ -165,12 +165,14 @@ class Delay(object):
def reply(self, obj): def reply(self, obj):
self.sent = 'reply' self.sent = 'reply'
self.protocol.send_reply(self.msgid, obj) if self.protocol:
self.protocol.send_reply(self.msgid, obj)
def error(self, exc_info): def error(self, exc_info):
self.sent = 'error' self.sent = 'error'
logger.error("Error raised in delayed method", exc_info=exc_info) logger.error("Error raised in delayed method", exc_info=exc_info)
self.protocol.send_error(self.msgid, exc_info[1]) if self.protocol:
self.protocol.send_error(self.msgid, exc_info[1])
def __repr__(self): def __repr__(self):
return "%s[%s, %r, %r, %r]" % ( return "%s[%s, %r, %r, %r]" % (
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment