Unverified Commit 68315116 authored by Sebastian Schüpbach's avatar Sebastian Schüpbach
Browse files

report more extensively

parent d1863c89
Pipeline #20918 passed with stages
in 5 minutes and 29 seconds
......@@ -32,7 +32,7 @@ object Dependencies {
lazy val log4jScala = "org.apache.logging.log4j" %% "log4j-api-scala" % "11.0"
lazy val log4jSlf4j = "org.apache.logging.log4j" % "log4j-slf4j-impl" % log4jV
lazy val mediaMetadataUtils =
"ch.memobase" %% "media-metadata-utils" % "0.1.3"
"ch.memobase" %% "media-metadata-utils" % "0.1.4"
lazy val scalaTest = "org.scalatest" %% "scalatest" % scalatestV
lazy val scalaUri = "io.lemonlabs" %% "scala-uri" % "2.2.3"
}
......@@ -76,9 +76,9 @@ class KafkaTopology extends Logging {
.mapValues(v => setMediaPlayerType(v))
.mapValues(v => (v._1, filterEnrichableResources(v._2)))
.branch(
(_, v) => v._2.nonEmpty && v._2.forall(_.player == ImageViewer),
(_, v) => v._2.nonEmpty,
(_, v) => v._2.isEmpty
(_, v) => v._2.forall(v => v.enrichable && v.player == ImageViewer),
(_, v) => v._2.forall(_.enrichable),
(_, _) => true
)
private def checkForLocators(stream: KStream[String, String]) =
......@@ -140,7 +140,7 @@ class KafkaTopology extends Logging {
.mkString("; ")
ReportingObject(
k,
ProcessingSuccess,
ProcessingIgnore,
s"Record is not enrichable; $distributedOn"
).toString
})
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment