diff --git a/src/serve.py b/src/serve.py index e6d1587..970f24c 100644 --- a/src/serve.py +++ b/src/serve.py @@ -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