Add handling for NotPrimaryError
continuous-integration/drone Build is passing
Details
continuous-integration/drone Build is passing
Details
This commit is contained in:
parent
1e3f16ca02
commit
2ccd734ba5
|
@ -202,13 +202,15 @@ async def uploader(coll, queue):
|
||||||
if not messages:
|
if not messages:
|
||||||
continue
|
continue
|
||||||
try:
|
try:
|
||||||
# TODO: Don't retry submitting messages commit by bulk insert above
|
|
||||||
then = time()
|
then = time()
|
||||||
await coll.insert_many(messages)
|
await coll.insert_many(messages)
|
||||||
histogram_database_operation_latency.labels("insert-many").observe(time() - then)
|
histogram_database_operation_latency.labels("insert-many").observe(time() - then)
|
||||||
except pymongo.errors.ServerSelectionTimeoutError:
|
except pymongo.errors.ServerSelectionTimeoutError:
|
||||||
counter_bulk_insertions.labels("timed-out").inc()
|
counter_bulk_insertions.labels("timed-out").inc()
|
||||||
continue
|
continue
|
||||||
|
except pymongo.errors.NotPrimaryError:
|
||||||
|
counter_bulk_insertions.labels("not-primary").inc()
|
||||||
|
continue
|
||||||
except pymongo.errors.BulkWriteError as e:
|
except pymongo.errors.BulkWriteError as e:
|
||||||
counter_bulk_insertions.labels("retried-as-singles").inc()
|
counter_bulk_insertions.labels("retried-as-singles").inc()
|
||||||
j = "%s.%s" % (e.__class__.__module__, e.__class__.__name__)
|
j = "%s.%s" % (e.__class__.__module__, e.__class__.__name__)
|
||||||
|
|
Loading…
Reference in New Issue