We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent a421c30 commit 156e825Copy full SHA for 156e825
1 file changed
transact/src/main/java/dev/dbos/transact/database/StepsDAO.java
@@ -94,11 +94,11 @@ static void recordStepResultTxn(
94
try (ResultSet rs = pstmt.executeQuery()) {
95
if (rs.next() && endTimeEpochMs != null) {
96
long completedAt = rs.getLong("completed_at_epoch_ms");
97
- logger.warn(
98
- String.format(
99
- "Step output for %s:%d-%s was already recorded",
100
- result.workflowId(), result.stepId(), result.functionName()));
101
if (completedAt != endTimeEpochMs) {
+ logger.warn(
+ String.format(
+ "Step output for %s:%d-%s was already recorded",
+ result.workflowId(), result.stepId(), result.functionName()));
102
throw new DBOSWorkflowExecutionConflictException(result.workflowId());
103
}
104
0 commit comments