Skip to content

Commit 9d361ef

Browse files
committed
fix(send_kcidb.py): Do not crash if findfast fails
In some cases (broken nodes) we might crash on HTTP/4xx reply. Do not crash, still process events. Signed-off-by: Denys Fedoryshchenko <denys.f@collabora.com>
1 parent 3634a56 commit 9d361ef

File tree

1 file changed

+10
-6
lines changed

1 file changed

+10
-6
lines changed

src/send_kcidb.py

Lines changed: 10 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -601,12 +601,16 @@ def _find_unprocessed_node(self, chunksize):
601601
if self._last_unprocessed_search and \
602602
time.time() - self._last_unprocessed_search < 5 * 60:
603603
return None
604-
nodes = self._api.node.findfast({
605-
'state': 'done',
606-
'processed_by_kcidb_bridge': False,
607-
'created__gt': datetime.datetime.now() - datetime.timedelta(days=4),
608-
'limit': chunksize
609-
})
604+
try:
605+
nodes = self._api.node.findfast({
606+
'state': 'done',
607+
'processed_by_kcidb_bridge': False,
608+
'created__gt': datetime.datetime.now() - datetime.timedelta(days=4),
609+
'limit': chunksize,
610+
})
611+
except Exception as exc:
612+
self.log.error(f"Failed to find unprocessed nodes: {str(exc)}")
613+
return []
610614

611615
if len(nodes) < chunksize:
612616
self._last_unprocessed_search = time.time()

0 commit comments

Comments
 (0)