Skip to content

Commit

Permalink
added type check for pipeline aggregator types in Transform initializ…
Browse files Browse the repository at this point in the history
…ation (#1014)

Signed-off-by: n-dohrmann <noah@dohrmann.org>
Co-authored-by: Joanne Wang <109310487+jowg-amazon@users.noreply.github.com>
(cherry picked from commit cd99b0f)
Signed-off-by: github-actions[bot] <github-actions[bot]@users.noreply.github.com>
  • Loading branch information
github-actions[bot] and jowg-amazon committed Nov 1, 2023
1 parent 0611a1a commit 829e55a
Showing 1 changed file with 3 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -77,6 +77,9 @@ data class Transform(
aggregations.aggregatorFactories.forEach {
require(supportedAggregations.contains(it.type)) { "Unsupported aggregation [${it.type}]" }
}
aggregations.pipelineAggregatorFactories.forEach {
require(supportedAggregations.contains(it.type)) { "Unsupported aggregation [${it.type}]" }
}
when (jobSchedule) {
is CronSchedule -> {
// Job scheduler already correctly throws errors for this
Expand Down

0 comments on commit 829e55a

Please sign in to comment.