We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
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
When custom/unknown measure is added a later request of measure is requested from Atum server if fails with exception.
Steps to reproduce the behavior OR commands run:
UnknownMeasure
AtumPartitioing
AtumContext
private def createMeasure(measure: MeasureDTO): za.co.absa.atum.agent.model.AtumMeasure = { val measuredColumns = measure.measuredColumns measure.measureName match { case RecordCount.measureName => RecordCount() case DistinctRecordCount.measureName => DistinctRecordCount(measuredColumns) case SumOfValuesOfColumn.measureName => SumOfValuesOfColumn(measuredColumns.head) case AbsSumOfValuesOfColumn.measureName => AbsSumOfValuesOfColumn(measuredColumns.head) case SumOfHashesOfColumn.measureName => SumOfHashesOfColumn(measuredColumns.head) case unsupportedMeasure => throw MeasureException( s"Measure not supported: $unsupportedMeasure. Supported measures are: ${AtumMeasure.supportedMeasureNames}" ) } }
Instance of UnknownMeasure is created. And it won't be evaluated on createCheckpoint call.
createCheckpoint
The text was updated successfully, but these errors were encountered:
salamonpavel
Successfully merging a pull request may close this issue.
Describe the bug
When custom/unknown measure is added a later request of measure is requested from Atum server if fails with exception.
To Reproduce
Steps to reproduce the behavior OR commands run:
UnknownMeasure
to anAtumPartitioing
AtumContext
Responsible code
Expected behavior
Instance of
UnknownMeasure
is created. And it won't be evaluated oncreateCheckpoint
call.The text was updated successfully, but these errors were encountered: