summaryrefslogtreecommitdiff
path: root/src/leap/soledad/client/incoming.py
diff options
context:
space:
mode:
authorVictor Shyba <victor1984@riseup.net>2017-08-07 21:09:44 -0300
committerVictor Shyba <victor1984@riseup.net>2017-08-07 21:09:44 -0300
commit90c8ebd220b0e15b75e9c1efc6c760f8b6592c4f (patch)
treee0bda12a90c8b3d3a32cf4de08096a3da85a8d97 /src/leap/soledad/client/incoming.py
parentfaa01b5858f9a7a80edb2120f3d767891801b897 (diff)
[bug] skip processing if no consumers to avoid data loss
Diffstat (limited to 'src/leap/soledad/client/incoming.py')
-rw-r--r--src/leap/soledad/client/incoming.py2
1 files changed, 2 insertions, 0 deletions
diff --git a/src/leap/soledad/client/incoming.py b/src/leap/soledad/client/incoming.py
index 879684e8..42522303 100644
--- a/src/leap/soledad/client/incoming.py
+++ b/src/leap/soledad/client/incoming.py
@@ -73,6 +73,8 @@ class IncomingBoxProcessingLoop:
@defer.inlineCallbacks
def _process(self):
+ if not self.consumers:
+ defer.returnValue(None)
pending = yield self.incoming_box.list_pending()
for item_id in pending:
item = yield self.incoming_box.fetch_for_processing(item_id)