Added Exception loggers on get_resource_items

ProzorroUKR · Jan 14, 2019 · 910d6c0 · 910d6c0
1 parent bee01fc
commit 910d6c0
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/openprocurement_client/resources/sync.py b/openprocurement_client/resources/sync.py
@@ -140,9 +140,13 @@ def get_resource_items(self):
                     LOGGER.info('Stop check backward worker')
                     check_down_worker = False
                 else:
+                    if not self.backward_worker.successful():
+                        LOGGER.warning('Exception from forward_worker: {}'.format(repr(self.backward_worker.exception)))
                     self.restart_sync()
                     check_down_worker = True
             if self.forward_worker.ready():
+                if not self.forward_worker.successful():
+                    LOGGER.warning('Exception from forward_worker: {}'.format(repr(self.forward_worker.exception)))
                 self.restart_sync()
                 check_down_worker = True
             while not self.queue.empty():