add additional info logging
This commit is contained in:
parent
6b75ef22c9
commit
4830b1cb91
@ -48,12 +48,14 @@ def process_request(request_message):
|
||||
pipeline = load_pipeline(verbose=IMAGE_CONFIG.service.verbose, batch_size=IMAGE_CONFIG.service.batch_size)
|
||||
|
||||
if storage.exists(bucket, target_file_name):
|
||||
logger.info("fetching file for file_id=%s, and daossier_id=%s", file_id, dossier_id)
|
||||
# should_publish_result = True
|
||||
object_bytes = storage.get_object(bucket, target_file_name)
|
||||
object_bytes = gzip.decompress(object_bytes)
|
||||
classifications = list(pipeline(pdf=object_bytes))
|
||||
|
||||
if storage.exists(bucket, figure_data_file_name):
|
||||
logger.info("fetching figures for file_id=%s, and daossier_id=%s", file_id, dossier_id)
|
||||
metadata_bytes = storage.get_object(bucket, figure_data_file_name)
|
||||
metadata_bytes = gzip.decompress(metadata_bytes)
|
||||
metadata_per_image = json.load(io.BytesIO(metadata_bytes))["data"]
|
||||
@ -68,6 +70,7 @@ def process_request(request_message):
|
||||
|
||||
return {"dossierId": dossier_id, "fileId": file_id}
|
||||
else:
|
||||
logger.info("no files found for file_id=%s, and daossier_id=%s", file_id, dossier_id)
|
||||
return None
|
||||
|
||||
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user