Fixed payload passing

GrigoriyPA · GrigoriyPA · commit 42238be41fe8 · 2024-11-25T19:37:04.000Z
diff --git a/ydb/library/yql/dq/actors/common/retry_queue.h b/ydb/library/yql/dq/actors/common/retry_queue.h
@@ -189,6 +189,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
`@@ -189,6 +189,9 @@ class TRetryEventsQueue {`
`189`	`189`	`THolder<T> ev = MakeHolder<T>();`
`190`	`190`	`ev->Record = Event->Record;`
`191`	`191`	`ev->Record.MutableTransportMeta()->SetConfirmedSeqNo(confirmedSeqNo);`
	`192`	`+ for (ui64 i = 0; i < Event->GetPayloadCount(); ++i) {`
	`193`	`+ ev->AddPayload(TRope(Event->GetPayload(i)));`
	`194`	`+ }`
`192`	`195`	`return MakeHolder<NActors::IEventHandle>(Recipient, Sender, ev.Release(), NActors::IEventHandle::FlagTrackDelivery, Cookie);`
`193`	`196`	`}`
`194`	`197`