Skip to content
Snippets Groups Projects
Commit 59362454 authored by Erik Johnston's avatar Erik Johnston
Browse files

Must update pending_transactions map before yield'ing

parent 852816be
No related branches found
No related tags found
No related merge requests found
...@@ -224,6 +224,8 @@ class TransactionQueue(object): ...@@ -224,6 +224,8 @@ class TransactionQueue(object):
] ]
try: try:
self.pending_transactions[destination] = 1
limiter = yield get_retry_limiter( limiter = yield get_retry_limiter(
destination, destination,
self._clock, self._clock,
...@@ -239,8 +241,6 @@ class TransactionQueue(object): ...@@ -239,8 +241,6 @@ class TransactionQueue(object):
len(pending_failures) len(pending_failures)
) )
self.pending_transactions[destination] = 1
logger.debug("TX [%s] Persisting transaction...", destination) logger.debug("TX [%s] Persisting transaction...", destination)
transaction = Transaction.create_new( transaction = Transaction.create_new(
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment