Remove transaction annotations

Signed-off-by: Michael Collado <collado.mike@gmail.com>
MarquezProject · Jul 12, 2022 · bb623df · bb623df
1 parent 0d58f2f
commit bb623df
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/api/src/main/java/marquez/db/JobVersionDao.java b/api/src/main/java/marquez/db/JobVersionDao.java
@@ -293,7 +293,6 @@ default List<UUID> findOutputDatasetsFor(UUID jobVersionUuid) {
    * @param transitionedAt The timestamp of the run state transition.
    * @return A {@link BagOfJobVersionInfo} object.
    */
-  @Transaction
   default BagOfJobVersionInfo upsertJobVersionOnRunTransition(
       @NonNull JobRow jobRow,
       @NonNull UUID runUuid,
@@ -324,7 +323,9 @@ default BagOfJobVersionInfo upsertJobVersionOnRunTransition(
     final Version jobVersion =
         Utils.newJobVersionFor(
             NamespaceName.of(jobRow.getNamespaceName()),
-            JobName.of(jobRow.getName()),
+            JobName.of(Optional.ofNullable(jobRow.getParentJobName())
+                .map(pn -> pn + "." + jobRow.getSimpleName())
+                    .orElse(jobRow.getName())),
             toDatasetIds(jobVersionInputs),
             toDatasetIds(jobVersionOutputs),
             jobContext,

diff --git a/api/src/main/java/marquez/db/OpenLineageDao.java b/api/src/main/java/marquez/db/OpenLineageDao.java
@@ -83,7 +83,6 @@ void createLineageEvent(
       PGobject event,
       String producer);
 
-  @Transaction
   default UpdateLineageRow updateMarquezModel(LineageEvent event, ObjectMapper mapper) {
     UpdateLineageRow updateLineageRow = updateBaseMarquezModel(event, mapper);
     RunState runState = getRunState(event.getEventType());