diff --git a/eox_nelp/pearson_vue/pipeline.py b/eox_nelp/pearson_vue/pipeline.py index bc5288d6..6db36986 100644 --- a/eox_nelp/pearson_vue/pipeline.py +++ b/eox_nelp/pearson_vue/pipeline.py @@ -400,12 +400,12 @@ def audit_error_validation(*args, **kwargs): Returns: None """ - @audit_method(action="Error Pearson Vue save audit data") - def audit_exception(*args, **kwargs): + @audit_method(action="Pearson Vue Error validation data") + def raise_audit_validation_exception(*args, **kwargs): raise ValueError(*args, kwargs) try: - audit_exception(*args, **kwargs) + raise_audit_validation_exception(*args, **kwargs) except ValueError: pass logger.error("Validation Error args:%s-kwargs:%s", args, kwargs) diff --git a/eox_nelp/pearson_vue/rti_backend.py b/eox_nelp/pearson_vue/rti_backend.py index 1434c5d0..4a1cd8de 100644 --- a/eox_nelp/pearson_vue/rti_backend.py +++ b/eox_nelp/pearson_vue/rti_backend.py @@ -59,14 +59,14 @@ def run_pipeline(self): if result.get("safely_pipeline_termination"): self.backend_data["pipeline_index"] = len(pipeline) - 1 break + if result.get("launch_validation_error_pipeline"): self.backend_data["pipeline_index"] = len(pipeline) - 1 - # clean kwargs to dont finish next pipeline. + # clean kwargs to dont finish next pipeline launch. error_validation_kwargs = remove_keys_from_dict( self.backend_data, ["pipeline_index", "launch_validation_error_pipeline"] ) - tasks = importlib.import_module("eox_nelp.pearson_vue.tasks") tasks.error_validation_task.delay(**error_validation_kwargs) break