Skip to content

Commit

Permalink
fix code formatting
Browse files Browse the repository at this point in the history
Signed-off-by: sophiely <ly.sophie200@gmail.com>
  • Loading branch information
sophiely committed Jan 23, 2024
1 parent 629c9e8 commit 50d3507
Showing 1 changed file with 10 additions and 9 deletions.
19 changes: 10 additions & 9 deletions api/src/main/java/marquez/service/LineageService.java
Original file line number Diff line number Diff line change
Expand Up @@ -116,16 +116,17 @@ public Lineage lineage(NodeId nodeId, int depth, boolean withRunFacets) {
}

if (nodeId.isDatasetType()) {
DatasetId datasetId = nodeId.asDatasetId();
DatasetData datasetData = this.getDatasetData(datasetId.getNamespace().getValue(), datasetId.getName().getValue());
DatasetId datasetId = nodeId.asDatasetId();
DatasetData datasetData =
this.getDatasetData(datasetId.getNamespace().getValue(), datasetId.getName().getValue());

if (!datasetIds.contains(datasetData.getUuid())) {
log.warn(
"Found jobs {} which no longer share lineage with dataset '{}' - discarding",
jobData.stream().map(JobData::getId).toList(),
nodeId.getValue());
return toLineageWithOrphanDataset(nodeId.asDatasetId());
}
if (!datasetIds.contains(datasetData.getUuid())) {
log.warn(
"Found jobs {} which no longer share lineage with dataset '{}' - discarding",
jobData.stream().map(JobData::getId).toList(),
nodeId.getValue());
return toLineageWithOrphanDataset(nodeId.asDatasetId());
}
}
return toLineage(jobData, datasets);
}
Expand Down

0 comments on commit 50d3507

Please sign in to comment.