Fixed payload passing

GrigoriyPA · GrigoriyPA · commit 53c8a838a14c · 2024-11-27T11:53:36.000Z
diff --git a/ydb/library/yql/dq/actors/common/retry_queue.h b/ydb/library/yql/dq/actors/common/retry_queue.h
@@ -186,6 +186,9 @@ class TRetryEventsQueue {
             THolder<T> ev = MakeHolder<T>();
             ev->Record = Event->Record;
             ev->Record.MutableTransportMeta()->SetConfirmedSeqNo(confirmedSeqNo);
+            for (ui64 i = 0; i < Event->GetPayloadCount(); ++i) {
+                ev->AddPayload(TRope(Event->GetPayload(i)));
+            }
             return MakeHolder<NActors::IEventHandle>(Recipient, Sender, ev.Release(), NActors::IEventHandle::FlagTrackDelivery, Cookie);
         }
 

Original file line number	Diff line number	Diff line change
`@@ -186,6 +186,9 @@ class TRetryEventsQueue {`
`186`	`186`	`THolder<T> ev = MakeHolder<T>();`
`187`	`187`	`ev->Record = Event->Record;`
`188`	`188`	`ev->Record.MutableTransportMeta()->SetConfirmedSeqNo(confirmedSeqNo);`
	`189`	`+ for (ui64 i = 0; i < Event->GetPayloadCount(); ++i) {`
	`190`	`+ ev->AddPayload(TRope(Event->GetPayload(i)));`
	`191`	`+ }`
`189`	`192`	`return MakeHolder<NActors::IEventHandle>(Recipient, Sender, ev.Release(), NActors::IEventHandle::FlagTrackDelivery, Cookie);`
`190`	`193`	`}`
`191`	`194`