diff --git a/mitogen/core.py b/mitogen/core.py index beeedd63..7fcad0ac 100644 --- a/mitogen/core.py +++ b/mitogen/core.py @@ -157,8 +157,9 @@ def _unpickle_dead(): _DEAD = Dead() -def has_parent_authority(msg, _stream): - return msg.auth_id in mitogen.parent_ids +def has_parent_authority(msg, _stream=None): + return (msg.auth_id == mitogen.context_id or + msg.auth_id in mitogen.parent_ids) def listen(obj, name, func):