From 852d4fd6b5ac8403022779321a530ca198e0328b Mon Sep 17 00:00:00 2001 From: AB019TC Date: Tue, 18 Jun 2024 10:57:42 +0200 Subject: [PATCH] using circe syntax in flow classes --- .../api/database/flows/functions/GetFlowCheckpoints.scala | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/server/src/main/scala/za/co/absa/atum/server/api/database/flows/functions/GetFlowCheckpoints.scala b/server/src/main/scala/za/co/absa/atum/server/api/database/flows/functions/GetFlowCheckpoints.scala index 0b30ee8d3..b8102987e 100644 --- a/server/src/main/scala/za/co/absa/atum/server/api/database/flows/functions/GetFlowCheckpoints.scala +++ b/server/src/main/scala/za/co/absa/atum/server/api/database/flows/functions/GetFlowCheckpoints.scala @@ -19,7 +19,6 @@ package za.co.absa.atum.server.api.database.flows.functions import doobie.Fragment import doobie.implicits.toSqlInterpolator import doobie.util.Read -import play.api.libs.json.Json import za.co.absa.atum.model.dto.CheckpointQueryDTO import za.co.absa.atum.server.api.database.PostgresDatabaseProvider import za.co.absa.atum.server.api.database.flows.Flows @@ -51,7 +50,7 @@ class GetFlowCheckpoints(implicit schema: DBSchema, dbEngine: DoobieEngine[Task] override def sql(values: CheckpointQueryDTO)(implicit read: Read[CheckpointFromDB]): Fragment = { val partitioning = PartitioningForDB.fromSeqPartitionDTO(values.partitioning) - val partitioningNormalized = Json.toJson(partitioning).toString + val partitioningNormalized = partitioning.asJson.noSpaces sql"""SELECT ${Fragment.const(selectEntry)} FROM ${Fragment.const(functionName)}(