diff --git a/eox_nelp/pearson_vue/pipeline.py b/eox_nelp/pearson_vue/pipeline.py index 9570f468..3ec733fd 100644 --- a/eox_nelp/pearson_vue/pipeline.py +++ b/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 ) diff --git a/eox_nelp/pearson_vue/rti_backend.py b/eox_nelp/pearson_vue/rti_backend.py index 1187f88c..88b538e5 100644 --- a/eox_nelp/pearson_vue/rti_backend.py +++ b/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): diff --git a/eox_nelp/pearson_vue/tests/test_pipeline.py b/eox_nelp/pearson_vue/tests/test_pipeline.py index 5bc3a777..2657e7d0 100644 --- a/eox_nelp/pearson_vue/tests/test_pipeline.py +++ b/eox_nelp/pearson_vue/tests/test_pipeline.py @@ -1253,7 +1253,7 @@ def test_audit_succesfull_cdd(self): f"INFO:{pipeline.__name__}:" 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: diff --git a/eox_nelp/pearson_vue/tests/test_rti_backend.py b/eox_nelp/pearson_vue/tests/test_rti_backend.py index 4bea1fc8..7801b990 100644 --- a/eox_nelp/pearson_vue/tests/test_rti_backend.py +++ b/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()