Fixes #189 - Changing back the details of flows.flows

AbsaOSS · Apr 30, 2024 · 6edc40a · 6edc40a
1 parent b3fc2bb
commit 6edc40a
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 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
@@ -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
@@ -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)
       }
   }