diff --git a/api/src/main/java/marquez/db/mappers/RunMapper.java b/api/src/main/java/marquez/db/mappers/RunMapper.java
index 3a1f95eb64..5bafbc2b52 100644
--- a/api/src/main/java/marquez/db/mappers/RunMapper.java
+++ b/api/src/main/java/marquez/db/mappers/RunMapper.java
@@ -68,7 +68,7 @@ public Run map(@NonNull ResultSet results, @NonNull StatementContext context)
         columnNames.contains(columnPrefix + Columns.STARTED_AT)
             ? timestampOrNull(results, columnPrefix + Columns.STARTED_AT)
             : null,
-        columnNames.contains(Columns.ENDED_AT)
+        columnNames.contains(columnPrefix + Columns.ENDED_AT)
             ? timestampOrNull(results, columnPrefix + Columns.ENDED_AT)
             : null,
         durationMs.orElse(null),