From 7a0b941cec393b693116fa0513764a1d59132b81 Mon Sep 17 00:00:00 2001 From: David Betancur Date: Wed, 11 Sep 2024 13:29:37 -0400 Subject: [PATCH] Adding uuid_url to app_context for correct api calling depending on environment. --- src/ingest-pipeline/airflow/dags/scan_and_begin_processing.py | 1 + src/ingest-pipeline/airflow/dags/validate_upload.py | 1 + 2 files changed, 2 insertions(+) diff --git a/src/ingest-pipeline/airflow/dags/scan_and_begin_processing.py b/src/ingest-pipeline/airflow/dags/scan_and_begin_processing.py index fcbf02fe5..090d9c443 100644 --- a/src/ingest-pipeline/airflow/dags/scan_and_begin_processing.py +++ b/src/ingest-pipeline/airflow/dags/scan_and_begin_processing.py @@ -117,6 +117,7 @@ def run_validation(**kwargs): ignore_globs = [uuid, "extras", "*metadata.tsv", "validation_report.txt"] app_context = { "entities_url": HttpHook.get_connection("entity_api_connection").host + "/entities/", + "uuid_url": HttpHook.get_connection("uuid_api_connection").host + "/uuid/", "ingest_url": os.environ["AIRFLOW_CONN_INGEST_API_CONNECTION"], "request_header": {"X-Hubmap-Application": "ingest-pipeline"}, } diff --git a/src/ingest-pipeline/airflow/dags/validate_upload.py b/src/ingest-pipeline/airflow/dags/validate_upload.py index 0852963c0..1bedb3a69 100644 --- a/src/ingest-pipeline/airflow/dags/validate_upload.py +++ b/src/ingest-pipeline/airflow/dags/validate_upload.py @@ -105,6 +105,7 @@ def run_validation(**kwargs): ignore_globs = [uuid, "extras", "*metadata.tsv", "validation_report.txt"] app_context = { "entities_url": HttpHook.get_connection("entity_api_connection").host + "/entities/", + "uuid_url": HttpHook.get_connection("uuid_api_connection").host + "/uuid/", "ingest_url": os.environ["AIRFLOW_CONN_INGEST_API_CONNECTION"], "request_header": {"X-Hubmap-Application": "ingest-pipeline"}, }