diff options
| author | Victor Shyba <victor1984@riseup.net> | 2017-08-07 21:09:44 -0300 |
|---|---|---|
| committer | Victor Shyba <victor1984@riseup.net> | 2017-08-07 21:09:44 -0300 |
| commit | 90c8ebd220b0e15b75e9c1efc6c760f8b6592c4f (patch) | |
| tree | e0bda12a90c8b3d3a32cf4de08096a3da85a8d97 /src/leap | |
| parent | faa01b5858f9a7a80edb2120f3d767891801b897 (diff) | |
[bug] skip processing if no consumers to avoid data loss
Diffstat (limited to 'src/leap')
| -rw-r--r-- | src/leap/soledad/client/incoming.py | 2 |
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) |