From 45dc96e7ededfc8621bb81fc5672a4a16f8225c5 Mon Sep 17 00:00:00 2001 From: Jeremy Nelson Date: Tue, 3 Dec 2024 14:05:22 -0800 Subject: [PATCH 1/2] bug: Change task dependency to retrieve sunid upstream task --- libsys_airflow/dags/new_boundwiths.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/libsys_airflow/dags/new_boundwiths.py b/libsys_airflow/dags/new_boundwiths.py index e922a244..28464bb9 100644 --- a/libsys_airflow/dags/new_boundwiths.py +++ b/libsys_airflow/dags/new_boundwiths.py @@ -102,7 +102,7 @@ def new_admin_notes(**kwargs): admin_note = generate_admin_note() - start >> [rows, admin_note] + start >> rows >> admin_note bw_records = add_bw_record.expand(row=rows) From 2fa5d0151e0fcb09d41ef065a2d24d924e788048 Mon Sep 17 00:00:00 2001 From: Jeremy Nelson Date: Tue, 3 Dec 2024 14:06:07 -0800 Subject: [PATCH 2/2] bug: Fixes column name to match expectation --- libsys_airflow/plugins/boundwith/boundwith_view.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/libsys_airflow/plugins/boundwith/boundwith_view.py b/libsys_airflow/plugins/boundwith/boundwith_view.py index 9437771b..6e3c5573 100644 --- a/libsys_airflow/plugins/boundwith/boundwith_view.py +++ b/libsys_airflow/plugins/boundwith/boundwith_view.py @@ -52,7 +52,7 @@ def run_bw_creation(self): raw_csv = request.files["upload-boundwith"] email_addr = request.form.get("user-email") bw_df = pd.read_csv(raw_csv) - if ["parts_holdings_hrid", "principle_barcode"] != list(bw_df.columns): + if ["part_holdings_hrid", "principle_barcode"] != list(bw_df.columns): flash(f"Invalid columns: {list(bw_df.columns)} for CSV file") rendered_page = self.render_template("boundwith/index.html") elif len(bw_df) > 1_000: