diff --git a/src/wattanalyse/external_interface.py b/src/wattanalyse/external_interface.py index cbd5df4..3414173 100644 --- a/src/wattanalyse/external_interface.py +++ b/src/wattanalyse/external_interface.py @@ -82,7 +82,12 @@ def pipeline_KPI_calculation( return return_code logger_database.info("Successfully saved metadata to database") - logger_pipeline.info("Pipeline >%s< ended successfully", PIPELINE_NAME) + if export_status_code == 0: + logger_pipeline.info("Pipeline >%s< ended successfully", PIPELINE_NAME) + else: + logger_pipeline.info( + "Pipeline >%s< ended with error. Code: %d", PIPELINE_NAME, export_status_code + ) logger_pipeline.info( "Pipeline >%s<: execution duration was %.4f seconds", PIPELINE_NAME,