Commit 263e3ee7 by Oleksandr Barabash

additional try except block added to pager.next()

parent b802da13
......@@ -142,7 +142,14 @@ class CosmosClient:
else:
pager = query_iterable.by_page()
Log.d(TAG, "get_initiation_items:: getting items")
new_items = list(pager.next())[0]
try:
new_items = list(pager.next())[0]
except Exception:
new_items = []
Log.e(TAG, "get_initiation_items:: oops, error",
exc_info=sys.exc_info())
Log.d(TAG, "get_initiation_items:: adding items")
items.append(new_items)
Log.d(TAG, "get_initiation_items:: getting token")
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment