spline #677 Consumer REST: Fix lineage-overview

AbsaOSS · Feb 26, 2021 · d689e2f · d689e2f
1 parent 7fd5725
commit d689e2f
Showing 1 changed file with 10 additions and 9 deletions.
diff --git a/...ices/src/main/scala/za/co/absa/spline/consumer/service/repo/OperationRepositoryImpl.scala b/...ices/src/main/scala/za/co/absa/spline/consumer/service/repo/OperationRepositoryImpl.scala
@@ -38,19 +38,20 @@ class OperationRepositoryImpl @Autowired()(db: ArangoDatabaseAsync) extends Oper
         |    LET inputs = (
         |        FOR v IN 1..1
         |            OUTBOUND ope follows
-        |            RETURN v.outputSchema
+        |            RETURN v
         |    )
         |
-        |    LET output = ope.outputSchema == null ? [] : [ope.outputSchema]
-        |
         |    LET schemas = (
-        |        FOR s in APPEND(inputs, output)
-        |            LET attributeList = (
-        |                FOR a IN []                                 // <<<<<<---- attrs ----!!!!!!!!!!!!---------
-        |                    FILTER CONTAINS(s, a.id)
-        |                    RETURN a
+        |        FOR op IN APPEND(inputs, ope)
+        |            LET schema = (
+        |                FOR attr IN 2 OUTBOUND op emits, consistsOf
+        |                    RETURN {
+        |                        "id": attr._key,
+        |                        "name": attr.name,
+        |                        "dataTypeId": attr.dataType
+        |                    }
         |            )
-        |            RETURN attributeList
+        |            RETURN schema
         |    )
         |
         |    LET dataTypesFormatted = (