From dba48ce6808931875d83b753ec29d97462bae250 Mon Sep 17 00:00:00 2001 From: Vitaly Stoyan Date: Tue, 22 Oct 2024 21:04:30 +0300 Subject: [PATCH] more replay fixes --- ydb/library/yql/core/facade/yql_facade.cpp | 5 +++++ ydb/library/yql/providers/common/provider/yql_provider.cpp | 7 +++++-- 2 files changed, 10 insertions(+), 2 deletions(-) diff --git a/ydb/library/yql/core/facade/yql_facade.cpp b/ydb/library/yql/core/facade/yql_facade.cpp index e5287e133d30..239f7d85215a 100644 --- a/ydb/library/yql/core/facade/yql_facade.cpp +++ b/ydb/library/yql/core/facade/yql_facade.cpp @@ -312,6 +312,11 @@ TProgram::TProgram( QContext_.GetWriter()->Put({FacadeComponent, StaticCredentialsLabel}, credList).GetValueSync(); } else if (QContext_.CanRead()) { Credentials_ = MakeIntrusive(); + Credentials_->SetUserCredentials({ + .OauthToken = "REPLAY_OAUTH", + .BlackboxSessionIdCookie = "REPLAY_SESSIONID" + }); + for (const auto& label : {StaticCredentialsLabel, DynamicCredentialsLabel}) { auto item = QContext_.GetReader()->Get({FacadeComponent, label}).GetValueSync(); if (item) { diff --git a/ydb/library/yql/providers/common/provider/yql_provider.cpp b/ydb/library/yql/providers/common/provider/yql_provider.cpp index 59c40e995835..c91b213a0a75 100644 --- a/ydb/library/yql/providers/common/provider/yql_provider.cpp +++ b/ydb/library/yql/providers/common/provider/yql_provider.cpp @@ -1155,12 +1155,15 @@ std::pair FreezeUsedF return SyncError(); } + if (types.QContext.CanRead()) { + return SyncOk(); + } + auto future = FreezeUserDataTableIfNeeded(types.UserDataStorage, files, urlDownloadFilter); if (future.Wait(TDuration::Zero())) { files = future.GetValue()(); return SyncOk(); - } - else { + } else { return std::make_pair(IGraphTransformer::TStatus::Async, future.Apply( [](const NThreading::TFuture>& completedFuture) { return TAsyncTransformCallback([completedFuture](const TExprNode::TPtr& input, TExprNode::TPtr& output, TExprContext& ctx) {