Skip to content

Commit 47d94f9

Browse files
committed
fix code formatting
1 parent 629c9e8 commit 47d94f9

File tree

1 file changed

+10
-9
lines changed

1 file changed

+10
-9
lines changed

api/src/main/java/marquez/service/LineageService.java

Lines changed: 10 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -116,16 +116,17 @@ public Lineage lineage(NodeId nodeId, int depth, boolean withRunFacets) {
116116
}
117117

118118
if (nodeId.isDatasetType()) {
119-
DatasetId datasetId = nodeId.asDatasetId();
120-
DatasetData datasetData = this.getDatasetData(datasetId.getNamespace().getValue(), datasetId.getName().getValue());
119+
DatasetId datasetId = nodeId.asDatasetId();
120+
DatasetData datasetData =
121+
this.getDatasetData(datasetId.getNamespace().getValue(), datasetId.getName().getValue());
121122

122-
if (!datasetIds.contains(datasetData.getUuid())) {
123-
log.warn(
124-
"Found jobs {} which no longer share lineage with dataset '{}' - discarding",
125-
jobData.stream().map(JobData::getId).toList(),
126-
nodeId.getValue());
127-
return toLineageWithOrphanDataset(nodeId.asDatasetId());
128-
}
123+
if (!datasetIds.contains(datasetData.getUuid())) {
124+
log.warn(
125+
"Found jobs {} which no longer share lineage with dataset '{}' - discarding",
126+
jobData.stream().map(JobData::getId).toList(),
127+
nodeId.getValue());
128+
return toLineageWithOrphanDataset(nodeId.asDatasetId());
129+
}
129130
}
130131
return toLineage(jobData, datasets);
131132
}

0 commit comments

Comments
 (0)