Skip to content

Commit

Permalink
#2213 Explicitly disable control metrics at the end of the job. (#2212)
Browse files Browse the repository at this point in the history
* Explicitly disable control metrics at the end of the job.

This is needed when the main method can be invoked more than once externally.

* Update spark-jobs/src/main/scala/za/co/absa/enceladus/standardization_conformance/StandardizationAndConformanceJob.scala

Co-authored-by: David Benedeki <[email protected]>

---------

Co-authored-by: David Benedeki <[email protected]>
  • Loading branch information
yruslan and benedeki authored Mar 21, 2024
1 parent a6d0ba6 commit db76241
Showing 1 changed file with 2 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -24,6 +24,7 @@ import za.co.absa.enceladus.utils.config.ConfigReader
import za.co.absa.enceladus.utils.modules.SourcePhase
import za.co.absa.enceladus.utils.types.{Defaults, DefaultsByFormat}
import za.co.absa.enceladus.utils.udf.UDFLibrary
import za.co.absa.atum.AtumImplicits._

object StandardizationAndConformanceJob extends StandardizationAndConformanceExecution {
private val jobName = "Enceladus Standardization&Conformance"
Expand Down Expand Up @@ -60,6 +61,7 @@ object StandardizationAndConformanceJob extends StandardizationAndConformanceExe
// post processing deliberately rereads the output ... same as above
runPostProcessing(SourcePhase.Conformance, preparationResult, cmd)
} finally {
spark.disableControlMeasuresTracking() //disabling Atum to enable running the whole process again, with fresh initialization
finishJob(cmd)
}
}
Expand Down

0 comments on commit db76241

Please sign in to comment.