diff --git a/.flake8 b/.flake8 deleted file mode 100644 index c82a5534..00000000 --- a/.flake8 +++ /dev/null @@ -1,3 +0,0 @@ -[flake8] -ignore=W503 -max-line-length = 100 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 a16636b4..19fcd2b6 100644 --- 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 index 8fbc8b96..66082092 100644 --- 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