feat: retrieve and include extra field in GET /execution-events

AbsaOSS · Jun 19, 2024 · 41609c1 · 41609c1
1 parent 4819469
commit 41609c1
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 3 deletions.
diff --git a/...mer-services/src/main/scala/za/co/absa/spline/consumer/service/model/WriteEventInfo.scala b/...mer-services/src/main/scala/za/co/absa/spline/consumer/service/model/WriteEventInfo.scala
@@ -43,9 +43,11 @@ case class WriteEventInfo
   @ApiModelProperty(value = "Output data source (or data) type")
   dataSourceType: String,
   @ApiModelProperty(value = "Write mode - (true=Append; false=Override)")
-  append: WriteEventInfo.Append
+  append: WriteEventInfo.Append,
+  @ApiModelProperty(value = "Other extra info")
+  extra: Map[String, Any]
 ) {
-  def this() = this(null, null, null, null, null, null, null, null, null, null, null, null)
+  def this() = this(null, null, null, null, null, null, null, null, null, null, null, null, null)
 }
 
 object WriteEventInfo {

diff --git a/...src/main/scala/za/co/absa/spline/consumer/service/repo/ExecutionEventRepositoryImpl.scala b/...src/main/scala/za/co/absa/spline/consumer/service/repo/ExecutionEventRepositoryImpl.scala
@@ -152,7 +152,8 @@ class ExecutionEventRepositoryImpl @Autowired()(db: ArangoDatabaseAsync) extends
          |        "dataSourceType"   : ee.execPlanDetails.dataSourceType,
          |        "append"           : ee.execPlanDetails.append,
          |        "durationNs"       : ee.durationNs,
-         |        "error"            : ee.error
+         |        "error"            : ee.error,
+         |        "extra"            : ee.extra
          |    }
          |
          |    SORT resItem.@sortField @sortOrder
@@ -192,5 +193,6 @@ object ExecutionEventRepositoryImpl {
     "extra.appId",
     "execPlanDetails.dataSourceUri",
     "execPlanDetails.dataSourceType",
+    "extra"
   )
 }