From 6edc40ab4e0a69c9abe88838f71f5c03d74eacac Mon Sep 17 00:00:00 2001 From: AB019TC Date: Tue, 30 Apr 2024 11:11:22 +0200 Subject: [PATCH] Fixes #189 - Changing back the details of flows.flows --- database/src/main/postgres/flows/V1.7.1__flows.alter.ddl | 2 +- .../absa/atum/database/runs/GetPartitioningMeasuresTest.scala | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/database/src/main/postgres/flows/V1.7.1__flows.alter.ddl b/database/src/main/postgres/flows/V1.7.1__flows.alter.ddl index e2ec77728..bb069ce6e 100644 --- a/database/src/main/postgres/flows/V1.7.1__flows.alter.ddl +++ b/database/src/main/postgres/flows/V1.7.1__flows.alter.ddl @@ -14,6 +14,6 @@ */ ALTER TABLE flows.flows - ALTER COLUMN fk_primary_partitioning SET NOT NULL; + ADD COLUMN IF NOT EXISTS fk_primary_partitioning BIGINT; CREATE UNIQUE INDEX IF NOT EXISTS unq_flows ON flows.flows (fk_primary_partitioning); diff --git a/database/src/test/scala/za/co/absa/atum/database/runs/GetPartitioningMeasuresTest.scala b/database/src/test/scala/za/co/absa/atum/database/runs/GetPartitioningMeasuresTest.scala index bf3d52c4a..234700cce 100644 --- a/database/src/test/scala/za/co/absa/atum/database/runs/GetPartitioningMeasuresTest.scala +++ b/database/src/test/scala/za/co/absa/atum/database/runs/GetPartitioningMeasuresTest.scala @@ -103,7 +103,7 @@ class GetPartitioningMeasuresTest extends DBTestSuite { .execute { queryResult => val results = queryResult.next() assert(results.getInt("status").contains(41)) - assert(results.getString("status_text").contains("Partitioning not found")) + assert(results.getString("status_text").contains("The partitioning does not exist.")) assert(!queryResult.hasNext) } }