Skip to content

Commit 38db610

Browse files
committed
truncate OffsetDateTime to MICROS for pipeline to run successfully
1 parent be9d60e commit 38db610

2 files changed

Lines changed: 2 additions & 2 deletions

File tree

src/main/java/it/aboutbits/springboot/emailservice/lib/application/ManageEmail.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -80,7 +80,6 @@ public EmailDto sendOrFail(@Valid EmailParameter parameter) throws EmailExceptio
8080

8181
email.setState(EmailState.SENDING);
8282
email.setExecutionStartTime(OffsetDateTime.now());
83-
email.setExecutionEndTime(null);
8483
email.setErrorMessage(null);
8584
email.incrementAttempts();
8685
emailRepository.save(email);

src/test/java/it/aboutbits/springboot/emailservice/lib/application/SendScheduledEmailsTest.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,6 +15,7 @@
1515
import org.springframework.test.context.bean.override.mockito.MockitoSpyBean;
1616

1717
import java.time.OffsetDateTime;
18+
import java.time.temporal.ChronoUnit;
1819
import java.util.concurrent.CountDownLatch;
1920
import java.util.concurrent.Executors;
2021
import java.util.concurrent.TimeUnit;
@@ -161,7 +162,7 @@ void givenStuckSendingRow_sendEmails_shouldRecoverAndResend() {
161162
void givenFreshSendingRowWithinThreshold_sendEmails_shouldNotStealFromOtherPod() {
162163
// executionStartTime within the 5-minute threshold means another pod is legitimately
163164
// sending this right now; we must not re-claim it.
164-
var recentStart = OffsetDateTime.now().minusSeconds(30);
165+
var recentStart = OffsetDateTime.now().minusSeconds(30).truncatedTo(ChronoUnit.MICROS);
165166
emailRepository.save(
166167
EmailFactory.once()
167168
.state(EmailState.SENDING)

0 commit comments

Comments
 (0)