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) 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: