Unverified Commit 88942c0f authored by Sebastian Schüpbach's avatar Sebastian Schüpbach
Browse files

rename reporting statuses


Signed-off-by: Sebastian Schüpbach's avatarSebastian Schüpbach <sebastian.schuepbach@unibas.ch>
parent 77247631
......@@ -304,7 +304,7 @@ class MediametadataToDB:
logging.info(f'Ignoring record {record_id} since' +
f' access of digitalObject is {access_status}')
reporter.send_message(record_id,
"SUCCESS",
"IGNORE",
"Ignoring record since access of " +
"digitalObject is unavailable")
if recordNo % 100 == 0:
......@@ -327,7 +327,7 @@ class MediametadataToDB:
status = 'It was not possible to consume the Kafka messages.' + '\n' + str(ex)
logging.error(status)
for record_value in record_values_for_db:
reporter.send_message(record_value['sig'], "FAILURE", f"Indexing failed: {ex}")
reporter.send_message(record_value['sig'], "FATAL", f"Indexing failed: {ex}")
def __init__(self):
# TODO : maybe take that to a configuration (development vs pod running in
......
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