diff options
| author | Erik Johnston <erik@matrix.org> | 2016-02-08 15:16:16 +0000 |
|---|---|---|
| committer | Erik Johnston <erik@matrix.org> | 2016-02-08 15:16:16 +0000 |
| commit | 2bb5f035affda14742ab715033570616621c0000 (patch) | |
| tree | 9348a7051ebb1d264afa47b2ce2d87c8b19f5523 /synapse/federation/transaction_queue.py | |
| parent | Merge pull request #562 from matrix-org/erikj/push_metric (diff) | |
| parent | Fix up logcontexts (diff) | |
| download | synapse-2bb5f035affda14742ab715033570616621c0000.tar.xz | |
Merge pull request #564 from matrix-org/erikj/logcontext
Fix up logcontexts
Diffstat (limited to 'synapse/federation/transaction_queue.py')
| -rw-r--r-- | synapse/federation/transaction_queue.py | 3 |
1 files changed, 0 insertions, 3 deletions
diff --git a/synapse/federation/transaction_queue.py b/synapse/federation/transaction_queue.py index 622adad3ae..1928da03b3 100644 --- a/synapse/federation/transaction_queue.py +++ b/synapse/federation/transaction_queue.py @@ -103,7 +103,6 @@ class TransactionQueue(object): else: return not destination.startswith("localhost") - @defer.inlineCallbacks def enqueue_pdu(self, pdu, destinations, order): # We loop through all destinations to see whether we already have # a transaction in progress. If we do, stick it in the pending_pdus @@ -141,8 +140,6 @@ class TransactionQueue(object): deferreds.append(deferred) - yield defer.DeferredList(deferreds, consumeErrors=True) - # NO inlineCallbacks def enqueue_edu(self, edu): destination = edu.destination |