Preserve log contexts correctly
This commit is contained in:
parent
d49cbf712f
commit
1246d23710
|
@ -226,7 +226,10 @@ class TransactionQueue(object):
|
||||||
events_by_room.setdefault(event.room_id, []).append(event)
|
events_by_room.setdefault(event.room_id, []).append(event)
|
||||||
|
|
||||||
yield logcontext.make_deferred_yieldable(defer.gatherResults(
|
yield logcontext.make_deferred_yieldable(defer.gatherResults(
|
||||||
[handle_room_events(evs) for evs in events_by_room.itervalues()],
|
[
|
||||||
|
logcontext.preserve_fn(handle_room_events)(evs)
|
||||||
|
for evs in events_by_room.itervalues()
|
||||||
|
],
|
||||||
consumeErrors=True
|
consumeErrors=True
|
||||||
))
|
))
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue