File tree Expand file tree Collapse file tree 1 file changed +2
-3
lines changed
ydb/core/kqp/session_actor Expand file tree Collapse file tree 1 file changed +2
-3
lines changed Original file line number Diff line number Diff line change @@ -532,10 +532,9 @@ class TKqpSessionActor : public TActorBootstrapped<TKqpSessionActor> {
532
532
}
533
533
534
534
bool AreAllTheTopicsAndPartitionsKnown () const {
535
- const NKikimrKqp::TTopicOperationsRequest& operations = QueryState->GetTopicOperations ();
535
+ const NKikimrKqp::TTopicOperationsRequest& operations = QueryState->GetTopicOperationsFromRequest ();
536
536
for (const auto & topic : operations.GetTopics ()) {
537
- auto path = CanonizePath (NPersQueue::GetFullTopicPath (TlsActivationContext->AsActorContext (),
538
- QueryState->GetDatabase (), topic.path ()));
537
+ auto path = CanonizePath (NPersQueue::GetFullTopicPath (QueryState->GetDatabase (), topic.path ()));
539
538
540
539
for (const auto & partition : topic.partitions ()) {
541
540
if (!QueryState->TxCtx ->TopicOperations .HasThisPartitionAlreadyBeenAdded (path, partition.partition_id ())) {
You can’t perform that action at this time.
0 commit comments