Bugfix calling IVT with new token naming

hubmapconsortium · Nov 7, 2023 · f3f509d · f3f509d
1 parent f9c6e70
commit f3f509d
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 5 deletions.
diff --git a/.flake8 b/.flake8
diff --git a/src/ingest-pipeline/airflow/dags/scan_and_begin_processing.py b/src/ingest-pipeline/airflow/dags/scan_and_begin_processing.py
@@ -118,7 +118,7 @@ def run_validation(**kwargs):
             # offline=True,  # noqa E265
             add_notes=False,
             ignore_deprecation=True,
-            token=get_auth_tok(**kwargs),
+            globus_token=get_auth_tok(**kwargs),
             cedar_api_key=airflow_conf.as_dict()["connections"]["CEDAR_API_KEY"],
         )
         # Scan reports an error result

diff --git a/src/ingest-pipeline/airflow/dags/validate_upload.py b/src/ingest-pipeline/airflow/dags/validate_upload.py
@@ -114,7 +114,7 @@ def run_validation(**kwargs):
             extra_parameters={
                 "coreuse": get_threads_resource("validate_upload", "run_validation")
             },
-            token=get_auth_tok(**kwargs),
+            globus_token=get_auth_tok(**kwargs),
             cedar_api_key=airflow_conf.as_dict()["connections"]["CEDAR_API_KEY"],
         )
         # Scan reports an error result