-
Notifications
You must be signed in to change notification settings - Fork 1
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
#105: Refactoring Measurement, from Agent side #104
Conversation
JaCoCo agent module code coverage report - spark:2 - scala 2.12.12Build Failed |
JaCoCo server module code coverage report - scala 2.12.12Build Failed |
… order there is not important
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This looks good. The only problem is that it cannot compile successfully, it has a type mismatch on found : scala.collection.immutable.Set[String] [error] required: Seq[Any] [error] val measureNames = scalaIterableToSQLArray(values.measurements.map(_.measure.measureName))
Fixed, thanks, it's already in master now |
JaCoCo agent module code coverage report - spark:2 - scala 2.12.18Build Failed |
JaCoCo server module code coverage report - scala 2.12.18Build Failed |
…-refactoring # Conflicts: # agent/src/main/scala/za/co/absa/atum/agent/AtumContext.scala # agent/src/main/scala/za/co/absa/atum/agent/model/Measure.scala # agent/src/main/scala/za/co/absa/atum/agent/model/MeasurementBuilder.scala # model/src/main/scala/za/co/absa/atum/model/dto/CheckpointDTO.scala
…-refactoring # Conflicts: # agent/src/main/scala/za/co/absa/atum/agent/AtumContext.scala # agent/src/main/scala/za/co/absa/atum/agent/exception/AtumAgentException.scala # agent/src/main/scala/za/co/absa/atum/agent/model/Measurement.scala # agent/src/test/scala/za/co/absa/atum/agent/model/MeasurementTest.scala # model/src/main/scala/za/co/absa/atum/model/dto/CheckpointDTO.scala
…-refactoring # Conflicts: # agent/src/main/scala/za/co/absa/atum/agent/AtumAgent.scala # agent/src/main/scala/za/co/absa/atum/agent/dispatcher/HttpDispatcher.scala # server/src/main/scala/za/co/absa/atum/server/api/database/Runs.scala
@@ -64,7 +64,7 @@ class AtumAgent private[agent] () { | |||
} | |||
|
|||
/** | |||
* Provides an AtumContext given a `AtumPartitions` instance. Retrieves the data from AtumService API. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
JaCoCo server module code coverage report - scala 2.13.11
|
JaCoCo agent module code coverage report - scala 2.12.18
|
JaCoCo model module code coverage report - scala 2.12.18
|
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Let's merge it. A major improvement.
agent/src/main/scala/za/co/absa/atum/agent/dispatcher/HttpDispatcher.scala
Show resolved
Hide resolved
agent/src/main/scala/za/co/absa/atum/agent/model/Measurement.scala
Outdated
Show resolved
Hide resolved
.github/workflows/build.yml
Outdated
- name: Build and run tests | ||
run: sbt ++${{matrix.scala}} test doc | ||
run: sbt "project server" ++${{matrix.scala}} test doc |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Aren't missing the db module (tests)?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
…ture using probably circe
… Java 11 uses different algorithm - JLS3 "Binary Compatibility" you can read more about it if interested; this PR addresses that and removes reflection completely from this SerDe
JaCoCo agent module code coverage report - scala 2.13.11
|
JaCoCo model module code coverage report - scala 2.13.11
|
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Let's get it in 😉
Addressing
Measurement
andMeasurementResult
- I tried to make it much more simpler and added some validations even. NowMeasure
contains only 2 attributes; the result itself is separated.I improved the MeasurementBuilder and now the
Measures
andMeasurements
areSet
but with some additional validation on uniqueness - i.e. a user can't define the same Measures against the same columns with different result values - it's not a valid case.Closes #105