Commit 80fdf951 authored by Denis Bilenko's avatar Denis Bilenko

proc: minor internal change:

- when notifying links, do not reschedule the rest of the links in case of
  an error; just print the traceback since that what the parent will do anyway
parent 890e7f0d
...@@ -77,6 +77,7 @@ and wait for all them to complete. Such function is provided by this module. ...@@ -77,6 +77,7 @@ and wait for all them to complete. Such function is provided by this module.
""" """
import sys import sys
from gevent import coros, greenlet, core from gevent import coros, greenlet, core
import traceback
__all__ = ['LinkedExited', __all__ = ['LinkedExited',
'LinkedFailed', 'LinkedFailed',
...@@ -421,8 +422,7 @@ class Source(object): ...@@ -421,8 +422,7 @@ class Source(object):
finally: finally:
consult.pop(listener, None) consult.pop(listener, None)
except: except:
core.active_event(self._do_send, links, consult) traceback.print_exc()
raise
def wait(self, timeout=None, exception=None): def wait(self, timeout=None, exception=None):
"""Wait until send() or send_exception() is called or `timeout' has """Wait until send() or send_exception() is called or `timeout' has
......
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