25-3-1: Fix listing for import changefeeds (#25685)

CyberROFL · web-flow · commit 23e3464d7aad · 2025-09-23T23:21:50.000+03:00
diff --git a/ydb/core/tx/schemeshard/schemeshard_import_getters.cpp b/ydb/core/tx/schemeshard/schemeshard_import_getters.cpp
@@ -677,7 +677,7 @@ class TSchemeGetter: public TGetterFromS3<TSchemeGetter> {
         ChangefeedsPrefixes.reserve(objects.size());
 
         for (const auto& obj : objects) {
-            const TFsPath& path = obj.GetKey();
+            const TFsPath path = obj.GetKey();
             if (path.GetName() == "changefeed_description.pb") {
                 ChangefeedsPrefixes.push_back(path.Parent().GetName());
             }
@@ -699,7 +699,7 @@ class TSchemeGetter: public TGetterFromS3<TSchemeGetter> {
 
     void ListChangefeeds() {
         CreateClient();
-        ListObjects(ImportInfo->GetItemSrcPrefix(ItemIdx));
+        ListObjects(ImportInfo->GetItemSrcPrefix(ItemIdx) + "/");
     }
 
     void DownloadMetadata() {

Original file line number	Diff line number	Diff line change
`@@ -677,7 +677,7 @@ class TSchemeGetter: public TGetterFromS3<TSchemeGetter> {`
`677`	`677`	`ChangefeedsPrefixes.reserve(objects.size());`
`678`	`678`
`679`	`679`	`for (const auto& obj : objects) {`
`680`		`- const TFsPath& path = obj.GetKey();`
	`680`	`+ const TFsPath path = obj.GetKey();`
`681`	`681`	`if (path.GetName() == "changefeed_description.pb") {`
`682`	`682`	`ChangefeedsPrefixes.push_back(path.Parent().GetName());`
`683`	`683`	`}`
`@@ -699,7 +699,7 @@ class TSchemeGetter: public TGetterFromS3<TSchemeGetter> {`
`699`	`699`
`700`	`700`	`void ListChangefeeds() {`
`701`	`701`	`CreateClient();`
`702`		`- ListObjects(ImportInfo->GetItemSrcPrefix(ItemIdx));`
	`702`	`+ ListObjects(ImportInfo->GetItemSrcPrefix(ItemIdx) + "/");`
`703`	`703`	`}`
`704`	`704`
`705`	`705`	`void DownloadMetadata() {`