diff --git a/api/src/main/java/marquez/db/DatasetFacetsDao.java b/api/src/main/java/marquez/db/DatasetFacetsDao.java index ce4a2556cd..30eb575330 100644 --- a/api/src/main/java/marquez/db/DatasetFacetsDao.java +++ b/api/src/main/java/marquez/db/DatasetFacetsDao.java @@ -153,9 +153,9 @@ default void insertDatasetFacetsFor( default void insertInputDatasetFacetsFor( @NonNull UUID datasetUuid, @NonNull UUID datasetVersionUuid, - @NonNull UUID runUuid, + @Nullable UUID runUuid, @NonNull Instant lineageEventTime, - @NonNull String lineageEventType, + @Nullable String lineageEventType, @NonNull LineageEvent.InputDatasetFacets inputFacets) { final Instant now = Instant.now(); @@ -179,9 +179,9 @@ default void insertInputDatasetFacetsFor( default void insertOutputDatasetFacetsFor( @NonNull UUID datasetUuid, @NonNull UUID datasetVersionUuid, - @NonNull UUID runUuid, + @Nullable UUID runUuid, @NonNull Instant lineageEventTime, - @NonNull String lineageEventType, + @Nullable String lineageEventType, @NonNull LineageEvent.OutputDatasetFacets outputFacets) { final Instant now = Instant.now();