-
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
#245 Add the ability to query REST endpoints from Reader module #297
#245 Add the ability to query REST endpoints from Reader module #297
Conversation
* created new module Info * the new modul added to JaCoco and CI routines
* JaCoCo exclusion for model
* created Provider to query the data from server * support for Future, IO, and ZIO based providers * work in progress
* fixed license headers
JaCoCo model module code coverage report - scala 2.13.11
|
JaCoCo agent module code coverage report - scala 2.13.11
|
JaCoCo reader module code coverage report - scala 2.13.11
|
JaCoCo server module code coverage report - scala 2.13.11
|
reader/src/main/scala/za/co/absa/atum/reader/server/GenericServerConnection.scala
Outdated
Show resolved
Hide resolved
model/src/main/scala/za/co/absa/atum/model/utils/JsonSyntaxExtensions.scala
Outdated
Show resolved
Hide resolved
model/src/test/scala/za/co/absa/atum/testing/implicits/StringImplicits.scala
Outdated
Show resolved
Hide resolved
reader/src/main/scala-2.13/za/co/absa/atum/reader/implicits/zio.scala
Outdated
Show resolved
Hide resolved
reader/src/main/scala/za/co/absa/atum/reader/implicits/io.scala
Outdated
Show resolved
Hide resolved
reader/src/test/scala-2.13/za/co/absa/atum/reader/basic/Reader_ZIOUnitTests.scala
Outdated
Show resolved
Hide resolved
reader/src/test/scala/za/co/absa/atum/reader/basic/Reader_CatsIOUnitTests.scala
Outdated
Show resolved
Hide resolved
reader/src/main/scala/za/co/absa/atum/reader/basic/Reader.scala
Outdated
Show resolved
Hide resolved
reader/src/main/scala/za/co/absa/atum/reader/basic/ReaderWithPartitioningId.scala
Outdated
Show resolved
Hide resolved
model/src/main/scala/za/co/absa/atum/model/utils/JsonSyntaxExtensions.scala
Show resolved
Hide resolved
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.
Should we not add some failure tests as well?
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.
The test now doesn't really test anything. They just ensure coverage numbers 🙄 .
The whole class is just a shell now, content will come in future tickets.
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.
Should we not add some failure tests as well?
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.
Ditto, just a shell of class.
reader/src/test/scala/za/co/absa/atum/reader/basic/PartitioningIdProviderUnitTests.scala
Outdated
Show resolved
Hide resolved
Co-authored-by: Ladislav Sulak <[email protected]>
…endpoints-from-info-module
reader/src/main/scala/za/co/absa/atum/reader/PartitioningReader.scala
Outdated
Show resolved
Hide resolved
reader/src/main/scala/za/co/absa/atum/reader/basic/Reader.scala
Outdated
Show resolved
Hide resolved
reader/src/test/scala/za/co/absa/atum/reader/FlowReaderUnitTests.scala
Outdated
Show resolved
Hide resolved
reader/src/test/scala/za/co/absa/atum/reader/PartitioningReaderUnitTests.scala
Outdated
Show resolved
Hide resolved
Co-authored-by: Ladislav Sulak <[email protected]>
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.
I didn't go very very deep and didn't try this on my localhost, but it looks good to me, approving
Reader
andPartitioningIdProvider
base classes for all readers - they are to bringAtum server connectivity/querying abilityRequestResult[R]
represents an Atum server query response.MonadError
type class needed forReader
andReaderWithPartitioningId
- there areFuture
, CatsIO
AtumPartitions
andAdditionalData
moved from Agent to ModuleErrorResponse
received a method to decode from Json based on http status codeCloses #245
Depends on #300
Release Notes: