Fixed describe of the transfer if topic not found

Author: nshestakov

ydb/core/transfer/ut/functional/transfer_ut.cpp

@@ -1311,5 +1311,42 @@ Y_UNIT_TEST_SUITE(Transfer)
         testCase.DropTopic();
         testCase.DropTable();
     }
+
+    Y_UNIT_TEST(DescribeTransferWithErrorTopicNotFound)
+    {
+        MainTestCase testCase;
+        testCase.CreateTable(R"(
+                CREATE TABLE `%s` (
+                    Key Uint64 NOT NULL,
+                    Message Utf8,
+                    PRIMARY KEY (Key)
+                )  WITH (
+                    STORE = %s
+                );
+            )");
+
+        testCase.CreateTransfer(R"(
+                $l = ($x) -> {
+                    return [
+                        <|
+                            Key:CAST($x._offset AS Uint64),
+                            Message:CAST($x._data AS Utf8)
+                        |>
+                    ];
+                };
+            )", MainTestCase::CreateTransferSettings::WithLocalTopic(false));
+
+        testCase.CheckTransferStateError("Path not found");
+
+        auto d = testCase.DescribeTransfer();
+        UNIT_ASSERT_VALUES_EQUAL(d.GetTransferDescription().GetState(), TTransferDescription::EState::Error);
+        UNIT_ASSERT_VALUES_EQUAL(d.GetTransferDescription().GetSrcPath(), TStringBuilder() << "local/" << testCase.TopicName);
+        UNIT_ASSERT_VALUES_EQUAL(d.GetTransferDescription().GetDstPath(), TStringBuilder() << "/local/" << testCase.TableName);
+
+        testCase.DropTransfer();
+        testCase.DropTable();
+    }
+
+
 }
 

ydb/core/tx/replication/controller/tx_describe_replication.cpp

@@ -198,6 +198,16 @@ class TController::TTxDescribeReplication: public TTxBase {
         }
 
         bool isTransfer = replication->GetConfig().HasTransferSpecific();
+        if (isTransfer) {
+            auto& specific = replication->GetConfig().GetTransferSpecific();
+
+            auto& transferSpecific = *Result->Record.MutableTransferSpecific();
+            transferSpecific.MutableTarget()->SetSrcPath(specific.GetTarget().GetSrcPath());
+            transferSpecific.MutableTarget()->SetDstPath(specific.GetTarget().GetDstPath());
+            transferSpecific.MutableTarget()->SetTransformLambda(specific.GetTarget().GetTransformLambda());
+            transferSpecific.MutableBatching()->CopyFrom(specific.GetBatching());
+        }
+
         for (ui64 tid = 0; tid < replication->GetNextTargetId(); ++tid) {
             auto* target = replication->FindTarget(tid);
             if (!target) {
@@ -209,11 +219,7 @@ class TController::TTxDescribeReplication: public TTxBase {
                 auto& specific = replication->GetConfig().GetTransferSpecific();
 
                 auto& transferSpecific = *Result->Record.MutableTransferSpecific();
-                transferSpecific.MutableTarget()->SetSrcPath(target->GetSrcPath());
-                transferSpecific.MutableTarget()->SetDstPath(target->GetDstPath());
                 transferSpecific.MutableTarget()->SetConsumerName(target->GetStreamConsumerName() ? target->GetStreamConsumerName() : specific.GetTarget().GetConsumerName());
-                transferSpecific.MutableTarget()->SetTransformLambda(specific.GetTarget().GetTransformLambda());
-                transferSpecific.MutableBatching()->CopyFrom(specific.GetBatching());
             }
 
             auto& item = *Result->Record.AddTargets();