Merge 365b533 into 4237dfb

CyberROFL · web-flow · commit 2cb332b2901f · 2024-02-05T13:58:42.000+03:00
diff --git a/ydb/services/datastreams/put_records_actor.h b/ydb/services/datastreams/put_records_actor.h
@@ -427,7 +427,7 @@ namespace NKikimr::NDataStreams::V1 {
                 for (int i = 0; i < PutRecordsResult.failed_record_count(); ++i) {
                     PutRecordsResult.add_records()->set_error_code("ThrottlingException");
                 }
-                this->CheckFinish(ctx);
+                return this->CheckFinish(ctx);
             default:
                 return this->HandleWakeup(ev, ctx);
         }

Original file line number	Diff line number	Diff line change
`@@ -427,7 +427,7 @@ namespace NKikimr::NDataStreams::V1 {`
`427`	`427`	`for (int i = 0; i < PutRecordsResult.failed_record_count(); ++i) {`
`428`	`428`	`PutRecordsResult.add_records()->set_error_code("ThrottlingException");`
`429`	`429`	`}`
`430`		`- this->CheckFinish(ctx);`
	`430`	`+ return this->CheckFinish(ctx);`
`431`	`431`	`default:`
`432`	`432`	`return this->HandleWakeup(ev, ctx);`
`433`	`433`	`}`