Skip to content

Commit

Permalink
upgrade openlineage java (#2677)
Browse files Browse the repository at this point in the history
Signed-off-by: Pawel Leszczynski <[email protected]>
  • Loading branch information
pawel-big-lebowski authored Nov 6, 2023
1 parent f6be002 commit 7c19162
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
4 changes: 2 additions & 2 deletions api/src/test/java/marquez/api/models/ActiveRun.java
Original file line number Diff line number Diff line change
Expand Up @@ -54,15 +54,15 @@ public String getJobName() {
}

public void startRun() {
olClient.emit(ol.newRunEvent(START, newEventTime(), run, job, inputs, outputs));
olClient.emit(ol.newRunEvent(newEventTime(), START, run, job, inputs, outputs));
}

public void endRun() {
endRun(COMPLETE);
}

public void endRun(@NonNull OpenLineage.RunEvent.EventType eventType) {
olClient.emit(ol.newRunEvent(eventType, newEventTime(), run, job, inputs, outputs));
olClient.emit(ol.newRunEvent(newEventTime(), eventType, run, job, inputs, outputs));
}

private static ZonedDateTime newEventTime() {
Expand Down
2 changes: 1 addition & 1 deletion build.gradle
Original file line number Diff line number Diff line change
Expand Up @@ -57,7 +57,7 @@ subprojects {
junit5Version = '5.10.0'
lombokVersion = '1.18.28'
mockitoVersion = '5.4.0'
openlineageVersion = '0.26.0'
openlineageVersion = '1.4.1'
slf4jVersion = '1.7.36'
postgresqlVersion = '42.6.0'
}
Expand Down

0 comments on commit 7c19162

Please sign in to comment.