Skip to content

Commit

Permalink
Fixing removed refs.
Browse files Browse the repository at this point in the history
Signed-off-by: phixMe <peter.hicks@pdtechsolutions.com>
  • Loading branch information
phixMe committed Oct 8, 2024
1 parent e816496 commit 6ae44db
Showing 1 changed file with 0 additions and 8 deletions.
8 changes: 0 additions & 8 deletions api/src/main/java/marquez/api/OpenLineageResource.java
Original file line number Diff line number Diff line change
Expand Up @@ -16,8 +16,6 @@
import com.fasterxml.jackson.core.JsonProcessingException;
import io.dropwizard.jersey.jsr310.ZonedDateTimeParam;
import java.sql.SQLException;
import java.time.Instant;
import java.time.ZoneId;
import java.util.Collections;
import java.util.List;
import java.util.concurrent.CompletionException;
Expand Down Expand Up @@ -70,12 +68,6 @@ public OpenLineageResource(
public void create(@Valid @NotNull BaseEvent event, @Suspended final AsyncResponse asyncResponse)
throws JsonProcessingException, SQLException {
if (event instanceof LineageEvent) {

Instant eventTime =
((LineageEvent) event).getEventTime().withZoneSameInstant(ZoneId.of("UTC")).toInstant();
String eventType = ((LineageEvent) event).getEventType();
serviceFactory.getStatsService().createCurrentDayLineageMetric(eventTime, eventType);
serviceFactory.getStatsService().createCurrentHourLineageMetric(eventTime, eventType);
if (serviceFactory.getSearchService().isEnabled()) {
serviceFactory.getSearchService().indexEvent((LineageEvent) event);
}
Expand Down

0 comments on commit 6ae44db

Please sign in to comment.