diff --git a/src/dve/core_engine/backends/base/reader.py b/src/dve/core_engine/backends/base/reader.py index eeeca7f..97cc710 100644 --- a/src/dve/core_engine/backends/base/reader.py +++ b/src/dve/core_engine/backends/base/reader.py @@ -165,9 +165,10 @@ def read_to_entity_type( entity=entity_name, record=None, failure_type="submission", - error_location=entity_name, error_code=config.error_code, error_message=config.error_message, + error_type="submission", + category="Empty entity", ) ], ) diff --git a/src/dve/pipeline/pipeline.py b/src/dve/pipeline/pipeline.py index 53185a0..66f5f85 100644 --- a/src/dve/pipeline/pipeline.py +++ b/src/dve/pipeline/pipeline.py @@ -930,6 +930,7 @@ def _get_error_dataframes(self, submission_id: str, include_record_rejections: b pl.col(column).cast(ERROR_SCHEMA[column]) # type: ignore for column in df.columns ) + df = df.with_columns(pl.col("Data_Item").fill_null("")) df = df.sort("Type", descending=False) # type: ignore errors_dfs.append(df)