File tree Expand file tree Collapse file tree
api/src/test/java/marquez/service Expand file tree Collapse file tree Original file line number Diff line number Diff line change 2828import marquez .common .models .JobId ;
2929import marquez .common .models .JobName ;
3030import marquez .common .models .NamespaceName ;
31- import marquez .common .models .OutputDatasetVersion ;
3231import marquez .common .models .RunState ;
3332import marquez .db .DatasetDao ;
3433import marquez .db .JobDao ;
@@ -172,11 +171,6 @@ public void testLineage() {
172171 .extracting (
173172 Run ::getInputDatasetVersions , InstanceOfAssertFactories .list (InputDatasetVersion .class ))
174173 .hasSize (0 );
175- runAssert
176- .extracting (
177- Run ::getOutputDatasetVersions ,
178- InstanceOfAssertFactories .list (OutputDatasetVersion .class ))
179- .hasSize (1 );
180174
181175 // check the output edges for the commonDataset node
182176 assertThat (lineage .getGraph ())
@@ -307,11 +301,6 @@ public void testLineageWithDeletedDataset() {
307301 .extracting (
308302 Run ::getInputDatasetVersions , InstanceOfAssertFactories .list (InputDatasetVersion .class ))
309303 .hasSize (0 );
310- runAssert
311- .extracting (
312- Run ::getOutputDatasetVersions ,
313- InstanceOfAssertFactories .list (InputDatasetVersion .class ))
314- .hasSize (1 );
315304
316305 // check the output edges for the commonDataset node
317306 assertThat (lineage .getGraph ())
You can’t perform that action at this time.
0 commit comments