17
17
package za .co .absa .atum .server .api .repository
18
18
19
19
import org .mockito .Mockito .{mock , when }
20
- import za .co .absa .atum .model .dto .{AdditionalDataDTO , MeasureDTO }
21
- import za .co .absa .atum .server .api .database .runs .functions .{
22
- CreateOrUpdateAdditionalData ,
23
- CreatePartitioningIfNotExists ,
24
- GetPartitioningAdditionalData ,
25
- GetPartitioningCheckpoints ,
26
- GetPartitioningMeasures }
27
- import za .co .absa .atum .server .api .exception .DatabaseError
28
20
import za .co .absa .atum .server .api .TestData
21
+ import za .co .absa .atum .server .api .database .runs .functions ._
22
+ import za .co .absa .atum .server .api .exception .DatabaseError
29
23
import za .co .absa .atum .server .model .CheckpointFromDB
30
24
import za .co .absa .fadb .exceptions .ErrorInDataException
31
25
import za .co .absa .fadb .status .FunctionStatus
@@ -126,7 +120,7 @@ object PartitioningRepositoryUnitTests extends ZIOSpecDefault with TestData {
126
120
test(" Returns expected Seq" ) {
127
121
for {
128
122
result <- PartitioningRepository .getPartitioningMeasures(partitioningDTO1)
129
- } yield assertTrue(result. isInstanceOf [ Seq [ MeasureDTO ]] && result == Seq (measureDTO1, measureDTO2))
123
+ } yield assertTrue(result == Seq (measureDTO1, measureDTO2))
130
124
},
131
125
test(" Returns expected Exception" ) {
132
126
assertZIO(PartitioningRepository .getPartitioningMeasures(partitioningDTO2).exit)(
@@ -139,7 +133,7 @@ object PartitioningRepositoryUnitTests extends ZIOSpecDefault with TestData {
139
133
test(" Returns expected Right with empty Map" ) {
140
134
for {
141
135
result <- PartitioningRepository .getPartitioningAdditionalData(partitioningDTO1)
142
- } yield assertTrue(result. isInstanceOf [ AdditionalDataDTO ] && result == additionalDataDTO1)
136
+ } yield assertTrue(result == additionalDataDTO1)
143
137
},
144
138
test(" Returns expected Left with DatabaseError" ) {
145
139
assertZIO(PartitioningRepository .getPartitioningAdditionalData(partitioningDTO2).exit)(
@@ -152,7 +146,7 @@ object PartitioningRepositoryUnitTests extends ZIOSpecDefault with TestData {
152
146
test(" Returns expected Seq" ) {
153
147
for {
154
148
result <- PartitioningRepository .getPartitioningCheckpoints(checkpointQueryDTO1)
155
- } yield assertTrue(result. isInstanceOf [ Seq [ CheckpointFromDB ]] && result == Seq (checkpointFromDB1))
149
+ } yield assertTrue(result == Seq (checkpointFromDB1))
156
150
},
157
151
test(" Returns expected DatabaseError" ) {
158
152
assertZIO(PartitioningRepository .getPartitioningCheckpoints(checkpointQueryDTO2).exit)(
0 commit comments