fix: add kwargs

Dont run the audit pipeline in error pipeline.

feat: add

eox_nelp/pearson_vue/pipeline.py

@@ -616,13 +616,7 @@ def get_enrollment_from_id(enrollment_id, enrollment=None, **kwargs):  # pylint:
     return {}
 
 
-def save_audit_pipeline(
-    pipeline_backend,
-    last_step,
-    cdd_import=None,
-    ead_import=None,
-    **kwargs
-):  # pylint: disable=unused-argument
+def save_audit_pipeline(pipeline_backend, last_step, cdd_import=None, ead_import=None, **kwargs):
     """This is not a pipe step, could be but its no the intention because inside a pipeline could
     be more than one import. so this is a helper for pipelines.
 
@@ -635,14 +629,20 @@ def save_audit_pipeline(
 
     @audit_method(action=f"Pearson Vue Pipeline Execution: {pipeline_backend}")
     @rename_function(name=f"audit_pipeline_{camel_to_snake(pipeline_backend)}")
-    def executed_pipeline(pipeline_backend, last_step, cdd_import, ead_import):
+    def executed_pipeline(
+        pipeline_backend,
+        last_step,
+        cdd_import,
+        ead_import,
+        **kwargs
+    ):  # pylint: disable=unused-argument
         logger.info(
-            "Pipeline %s executed until last step %s",
+            "Pipeline %s executed until last step: %s",
             pipeline_backend,
             last_step,
         )
         logger.info(
-            "Succesfull imports. cdd: %s. ead: %s",
+            "Succesfull imports. cdd_import: %s. ead_import: %s",
             cdd_import,
             ead_import,
         )
@@ -652,4 +652,5 @@ def executed_pipeline(pipeline_backend, last_step, cdd_import, ead_import):
         last_step=last_step,
         cdd_import=cdd_import,
         ead_import=ead_import,
+        **kwargs
     )

eox_nelp/pearson_vue/rti_backend.py

@@ -183,6 +183,7 @@ def handle_error(self, exception, failed_step_pipeline):
             exception_dict=exception.to_dict(),
             course_id=self.backend_data.get("course_id"),
             user_id=self.backend_data.get("user_id"),
+            use_audit_pipeline=False,
         )
 
     def get_pipeline(self):

eox_nelp/pearson_vue/tests/test_pipeline.py

@@ -1251,9 +1251,9 @@ def test_audit_succesfull_cdd(self):
         cdd_import = {}
         log_info = [
             f"INFO:{pipeline.__name__}:"
-            f"Pipeline {pipeline_backend} executed until last step {last_step}",
+            f"Pipeline {pipeline_backend} executed until last step: {last_step}",
             f"INFO:{pipeline.__name__}:"
-            f"Succesfull imports. cdd: {cdd_import}. ead: {None}",
+            f"Succesfull imports. cdd_import: {cdd_import}. ead_import: {None}",
         ]
 
         with self.assertLogs(pipeline.__name__, level="INFO") as logs:
@@ -1276,9 +1276,9 @@ def test_audit_succesfull_ead(self):
         ead_import = {}
         log_info = [
             f"INFO:{pipeline.__name__}:"
-            f"Pipeline {pipeline_backend} executed until last step {last_step}",
+            f"Pipeline {pipeline_backend} executed until last step: {last_step}",
             f"INFO:{pipeline.__name__}:"
-            f"Succesfull imports. cdd: {None}. ead: {ead_import}",
+            f"Succesfull imports. cdd_import: {None}. ead_import: {ead_import}",
         ]
 
         with self.assertLogs(pipeline.__name__, level="INFO") as logs:

eox_nelp/pearson_vue/tests/test_rti_backend.py

@@ -233,6 +233,7 @@ def test_launch_validation_error_pipeline(self, pearson_error, rti_error_handler
             exception_dict=pearson_error.to_dict(),
             user_id=None,
             course_id=None,
+            use_audit_pipeline=False,
         )
         audit_pipeline_mock.assert_not_called()