Skip to content

Commit 4995082

Browse files
committed
fix: state-based receipt notification rejection
Signed-off-by: Alexis Asseman <[email protected]>
1 parent 01336a1 commit 4995082

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

tap-agent/src/tap/sender_allocation_relationship.rs

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -147,12 +147,12 @@ impl SenderAllocationRelationship {
147147
&self,
148148
new_receipt_notification: NewReceiptNotification,
149149
) {
150-
// If we're in the last rav pending state, we don't want to process any new receipts.
151-
if self.state().await == State::LastRavPending {
150+
// If we're in the last rav pending state or finished, we don't want to process any new
151+
// receipts.
152+
if self.state().await != State::Running {
152153
error!(
153-
"Received a new receipt notification for allocation {} and sender {} while \
154-
the last RAV is pending. This should not have happened since this allocation \
155-
and/or sender is not eligible anymore.",
154+
"Received a new receipt notification for now ineligible allocation {} and \
155+
sender {}.",
156156
self.inner.allocation_id, self.inner.sender
157157
);
158158
return;

0 commit comments

Comments
 (0)