From 76b50eb3f6ffc540d395376ec46bba56f6288c54 Mon Sep 17 00:00:00 2001
From: st-shchetinin <st-shchetinin@ydb.tech>
Date: Wed, 19 Feb 2025 14:32:12 +0300
Subject: [PATCH] fix paths

---
 .../tx/schemeshard/schemeshard_import__create.cpp   | 13 -------------
 .../schemeshard_import_flow_proposals.cpp           |  6 ++----
 ydb/core/tx/schemeshard/schemeshard_info_types.h    |  1 -
 3 files changed, 2 insertions(+), 18 deletions(-)

diff --git a/ydb/core/tx/schemeshard/schemeshard_import__create.cpp b/ydb/core/tx/schemeshard/schemeshard_import__create.cpp
index 29558fd46f10..cea88fe74850 100644
--- a/ydb/core/tx/schemeshard/schemeshard_import__create.cpp
+++ b/ydb/core/tx/schemeshard/schemeshard_import__create.cpp
@@ -1061,10 +1061,6 @@ struct TSchemeShard::TImport::TTxProgress: public TSchemeShard::TXxport::TTxBase
             
             case EState::CreateChangefeed:
                 CreateChangefeed(importInfo, i, txId);
-                itemIdx = i;
-                break;
-            
-            case EState::CreateConsumers:
                 CreateConsumers(importInfo, i, txId);
                 itemIdx = i;
                 break;
@@ -1312,19 +1308,10 @@ struct TSchemeShard::TImport::TTxProgress: public TSchemeShard::TXxport::TTxBase
         case EState::CreateChangefeed:
             if (++item.NextChangefeedIdx < item.Changefeeds.GetChangefeeds().size()) {
                 AllocateTxId(importInfo, itemIdx);
-                item.State = EState::CreateConsumers;
             } else {
                 item.State = EState::Done;
             }
             break;
-        
-        case EState::CreateConsumers:
-            if (item.NextChangefeedIdx < item.Changefeeds.GetChangefeeds().size()) {
-                AllocateTxId(importInfo, itemIdx);
-                item.State = EState::CreateChangefeed;
-            } else {
-                item.State = EState::Done;
-            }
 
         default:
             return SendNotificationsIfFinished(importInfo);
diff --git a/ydb/core/tx/schemeshard/schemeshard_import_flow_proposals.cpp b/ydb/core/tx/schemeshard/schemeshard_import_flow_proposals.cpp
index 5324335fd3e5..d8382184913e 100644
--- a/ydb/core/tx/schemeshard/schemeshard_import_flow_proposals.cpp
+++ b/ydb/core/tx/schemeshard/schemeshard_import_flow_proposals.cpp
@@ -308,10 +308,8 @@ THolder<TEvSchemeShard::TEvModifySchemeTransaction> CreateConsumersPropose(
     auto& pqGroup = *modifyScheme.MutableAlterPersQueueGroup();
 
     const TPath dstPath = TPath::Init(item.DstPathId, ss);
-    Cerr << "pqGroup working dir: " << dstPath.Parent().PathString() << Endl;
-    Cerr << "pqGroup name: " << dstPath.LeafName() << Endl;
-    modifyScheme.SetWorkingDir(dstPath.Parent().PathString());
-    pqGroup.SetName(dstPath.LeafName());
+    modifyScheme.SetWorkingDir(dstPath.PathString());
+    pqGroup.SetName(importChangefeedTopic.GetChangefeed().name());
 
     for (const auto& consumer : topic.consumers()) {
         auto pqConsumer = *pqGroup.MutablePQTabletConfig()->AddConsumers();
diff --git a/ydb/core/tx/schemeshard/schemeshard_info_types.h b/ydb/core/tx/schemeshard/schemeshard_info_types.h
index f002e1061dcd..32f68f1f74a7 100644
--- a/ydb/core/tx/schemeshard/schemeshard_info_types.h
+++ b/ydb/core/tx/schemeshard/schemeshard_info_types.h
@@ -2829,7 +2829,6 @@ struct TImportInfo: public TSimpleRefCount<TImportInfo> {
         Transferring,
         BuildIndexes,
         CreateChangefeed,
-        CreateConsumers,
         Done = 240,
         Cancellation = 250,
         Cancelled = 251,