in webhook/main.py [0:0]
def cloud_event_entrypoint(event_id, bucket, name, time_created):
orig_pdf_uri = f"gs://{bucket}/{name}"
logging_client = logging.Client()
logger = logging_client.logger(_FUNCTIONS_VERTEX_EVENT_LOGGER)
logger.log(f"cloud_event_id({event_id}): UPLOAD {orig_pdf_uri}",
severity="INFO")
extracted_text = async_document_extract(bucket, name, output_bucket=_OUTPUT_BUCKET)
logger.log(
f"cloud_event_id({event_id}): OCR gs://{bucket}/{name}", severity="INFO"
)
return summarization_entrypoint(
name,
extracted_text,
time_created=time_created,
event_id=event_id,
bucket=bucket,
)