YQ-3900 Fix ScheduleHeartbeat() if already connected (#11888)

kardymonds · web-flow · commit fed023977807 · 2024-11-22T23:55:59.000+03:00
diff --git a/ydb/library/yql/dq/actors/common/retry_queue.cpp b/ydb/library/yql/dq/actors/common/retry_queue.cpp
@@ -35,6 +35,9 @@ void TRetryEventsQueue::OnNewRecipientId(const NActors::TActorId& recipientId, b
     ReceivedEventsSeqNos.clear();
     Connected = connected;
     RetryState = Nothing();
+    if (Connected) {
+        ScheduleHeartbeat();
+    }
 }
 
 void TRetryEventsQueue::HandleNodeDisconnected(ui32 nodeId) {

Original file line number	Diff line number	Diff line change
`@@ -35,6 +35,9 @@ void TRetryEventsQueue::OnNewRecipientId(const NActors::TActorId& recipientId, b`
`35`	`35`	`ReceivedEventsSeqNos.clear();`
`36`	`36`	`Connected = connected;`
`37`	`37`	`RetryState = Nothing();`
	`38`	`+ if (Connected) {`
	`39`	`+ ScheduleHeartbeat();`
	`40`	`+ }`
`38`	`41`	`}`
`39`	`42`
`40`	`43`	`void TRetryEventsQueue::HandleNodeDisconnected(ui32 nodeId) {`