diff --git a/database/src/main/postgres/runs/V1.8.3__get_partitioning_checkpoints.sql b/database/src/main/postgres/runs/V1.8.3__get_partitioning_checkpoints.sql index d7811ca24..ed2f466d0 100644 --- a/database/src/main/postgres/runs/V1.8.3__get_partitioning_checkpoints.sql +++ b/database/src/main/postgres/runs/V1.8.3__get_partitioning_checkpoints.sql @@ -64,7 +64,6 @@ RETURNS SETOF record AS -- -- Status codes: -- 11 - OK --- 12 - OK with no checkpoints found -- 41 - Partitioning not found -- ------------------------------------------------------------------------------- @@ -126,12 +125,6 @@ BEGIN runs.measure_definitions MD ON M.fk_measure_definition = MD.id_measure_definition ORDER BY LC.id_checkpoint, LC.process_start_time; - - IF NOT FOUND THEN - status := 12; - status_text := 'OK with no checkpoints found'; - RETURN NEXT; - END IF; END; $$ LANGUAGE plpgsql VOLATILE SECURITY DEFINER; diff --git a/database/src/test/scala/za/co/absa/atum/database/runs/GetPartitioningCheckpointsIntegrationTests.scala b/database/src/test/scala/za/co/absa/atum/database/runs/GetPartitioningCheckpointsIntegrationTests.scala index 59bfac6c8..21d623126 100644 --- a/database/src/test/scala/za/co/absa/atum/database/runs/GetPartitioningCheckpointsIntegrationTests.scala +++ b/database/src/test/scala/za/co/absa/atum/database/runs/GetPartitioningCheckpointsIntegrationTests.scala @@ -277,10 +277,6 @@ class GetPartitioningCheckpointsIntegrationTests extends DBTestSuite { .setParam("i_offset", 1) .setParam("i_checkpoint_name", i_checkpoint_name) .execute { queryResult => - assert(queryResult.hasNext) - val result = queryResult.next() - assert(result.getInt("status").contains(12)) - assert(result.getString("status_text").contains("OK with no checkpoints found")) assert(!queryResult.hasNext) }