This commit is contained in:
Julius Unverfehrt 2022-03-17 12:47:13 +01:00
parent 6a36f56a3e
commit 549b89952e

View File

@ -55,10 +55,7 @@ def build_message_bodies(analyse_container_type):
for bucket_name, pdf_name in storage.get_all_object_names(CONFIG.storage.bucket):
file_id = pdf_name.split(".")[0]
dossier_id, file_id = file_id.split("/")
message_dict = {
"dossierId": dossier_id,
"fileId": file_id
}
message_dict = {"dossierId": dossier_id, "fileId": file_id}
update_message(message_dict, analyse_container_type)
yield json.dumps(message_dict).encode()