style: fix linting

Author: vaibhavtiwari16

src/dve/pipeline/foundry_ddb_pipeline.py

@@ -10,6 +10,7 @@
     duckdb_get_entity_count,
     duckdb_write_parquet,
 )
+from dve.core_engine.configuration.v1 import V1ErrorReportConfig
 from dve.core_engine.exceptions import CriticalProcessingError
 from dve.core_engine.models import SubmissionInfo
 from dve.core_engine.type_hints import URI
@@ -101,10 +102,12 @@ def apply_business_rules(
             return submission_info, SubmissionStatus(processing_failed=True)
 
     def error_report(
-        self, submission_info: SubmissionInfo, submission_status: Optional[SubmissionStatus] = None
+        self, submission_info: SubmissionInfo,
+        submission_status: Optional[SubmissionStatus] = None ,
+        error_report_config: Optional[V1ErrorReportConfig] = None,
     ):
         try:
-            return super().error_report(submission_info, submission_status)
+            return super().error_report(submission_info, submission_status,error_report_config)
         except Exception as exc:  # pylint: disable=W0718
             self._logger.exception("Error reports raised exception:")
             sub_stats = None

src/dve/pipeline/pipeline.py

@@ -969,6 +969,8 @@ def error_report(
 
         self._logger.info("Reading error dataframes")
         if error_report_config is None:
+            if not self.rules_path:
+                raise AttributeError("rules path not provided")
             _, config, _ = load_config(submission_info.dataset_id, self.rules_path)
             error_report_config = config.error_report
         errors_df, aggregates = self._get_error_dataframes(

tests/test_pipeline/test_duckdb_pipeline.py

@@ -189,7 +189,7 @@ def test_error_report_step(
             audit_tables=audit_manager,
             job_run_id=1,
             connection=conn,
-            rules_path=None,
+            rules_path=PLANETS_RULES_PATH,
             submitted_files_path=None,
         )
 

tests/test_pipeline/test_spark_pipeline.py

@@ -516,7 +516,7 @@ def test_error_report_step(
             processed_files_path=processed_files_path,
             audit_tables=audit_manager,
             job_run_id=1,
-            rules_path=None,
+            rules_path=PLANETS_RULES_PATH,
             submitted_files_path=None,
             spark=spark,
         )