diff --git a/cdisc_rules_engine/utilities/data_processor.py b/cdisc_rules_engine/utilities/data_processor.py index 18cdcb99e..c7c846bd0 100644 --- a/cdisc_rules_engine/utilities/data_processor.py +++ b/cdisc_rules_engine/utilities/data_processor.py @@ -269,6 +269,9 @@ def merge_pivot_supp_dataset( ) ) DataProcessor._validate_qnam(left_dataset.data, qnam_list, common_keys) + for qnam in qnam_list: + if qnam in left_dataset.columns: + left_dataset.data[qnam] = left_dataset.data[qnam].fillna(pd.NA) if not is_blank: left_dataset[dynamic_key] = left_dataset[temp_key] left_dataset = left_dataset.drop(columns=[temp_key])