Skip to content

Commit 9e2671a

Browse files
committed
add conn to _mq.command call
1 parent 385b612 commit 9e2671a

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

sogs/events.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -115,7 +115,7 @@ def _propagate_event(eventname, *args):
115115
assert event_name_valid(eventname)
116116
global _mq
117117
for conn in _pool.get(eventname):
118-
_mq.command('sogs.event', eventname, *args)
118+
_mq.command('sogs.event', conn, eventname, *args)
119119

120120

121121
def _handle_request(handler, msg):

0 commit comments

Comments
 (0)