Don't use Now() during replay for yt settings (#10732)

vitstn · web-flow · commit 26b808fd6976 · 2024-10-22T23:42:05.000+03:00
diff --git a/ydb/library/yql/core/extract_predicate/ut/extract_predicate_ut.cpp b/ydb/library/yql/core/extract_predicate/ut/extract_predicate_ut.cpp
@@ -44,9 +44,8 @@ Y_UNIT_TEST_SUITE(TYqlExtractPredicate) {
         auto ytGateway = CreateYtFileGateway(yqlNativeServices);
         typesCtx = MakeIntrusive<TTypeAnnotationContext>();
         typesCtx->RandomProvider = CreateDeterministicRandomProvider(1);
-        auto ytState = MakeIntrusive<TYtState>();
+        auto ytState = MakeIntrusive<TYtState>(typesCtx.Get());
         ytState->Gateway = ytGateway;
-        ytState->Types = typesCtx.Get();
 
         InitializeYtGateway(ytGateway, ytState);
         typesCtx->AddDataSink(YtProviderName, CreateYtDataSink(ytState));
diff --git 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<TCredentials>();
+        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/core/ut/yql_expr_constraint_ut.cpp b/ydb/library/yql/core/ut/yql_expr_constraint_ut.cpp
@@ -31,9 +31,8 @@ Y_UNIT_TEST_SUITE(TYqlExprConstraints) {
         auto ytGateway = CreateYtFileGateway(yqlNativeServices);
         auto typeAnnotationContext = MakeIntrusive<TTypeAnnotationContext>();
         typeAnnotationContext->RandomProvider = CreateDeterministicRandomProvider(1);
-        auto ytState = MakeIntrusive<TYtState>();
+        auto ytState = MakeIntrusive<TYtState>(typeAnnotationContext.Get());
         ytState->Gateway = ytGateway;
-        ytState->Types = typeAnnotationContext.Get();
 
         InitializeYtGateway(ytGateway, ytState);
         typeAnnotationContext->AddDataSink(YtProviderName, CreateYtDataSink(ytState));
diff --git a/ydb/library/yql/core/ut/yql_expr_discover_ut.cpp b/ydb/library/yql/core/ut/yql_expr_discover_ut.cpp
@@ -31,9 +31,8 @@ Y_UNIT_TEST_SUITE(TDiscoverYqlExpr) {
         auto ytGateway = CreateYtFileGateway(yqlNativeServices);
         auto typeAnnotationContext = MakeIntrusive<TTypeAnnotationContext>();
         typeAnnotationContext->DiscoveryMode = true;
-        auto ytState = MakeIntrusive<TYtState>();
+        auto ytState = MakeIntrusive<TYtState>(typeAnnotationContext.Get());
         ytState->Gateway = ytGateway;
-        ytState->Types = typeAnnotationContext.Get();
 
         InitializeYtGateway(ytGateway, ytState);
         auto randomProvider = CreateDeterministicRandomProvider(1);
diff --git a/ydb/library/yql/core/ut/yql_expr_optimize_ut.cpp b/ydb/library/yql/core/ut/yql_expr_optimize_ut.cpp
@@ -592,9 +592,8 @@ Y_UNIT_TEST_SUITE(TOptimizeYqlExpr) {
         auto yqlNativeServices = NFile::TYtFileServices::Make(functionRegistry.Get(), testTables);
         auto ytGateway = CreateYtFileGateway(yqlNativeServices);
         auto typeAnnotationContext = MakeIntrusive<TTypeAnnotationContext>();
-        auto ytState = MakeIntrusive<TYtState>();
+        auto ytState = MakeIntrusive<TYtState>(typeAnnotationContext.Get());
         ytState->Gateway = ytGateway;
-        ytState->Types = typeAnnotationContext.Get();
 
         InitializeYtGateway(ytGateway, ytState);
         auto randomProvider = CreateDeterministicRandomProvider(1);
diff --git a/ydb/library/yql/core/ut/yql_expr_providers_ut.cpp b/ydb/library/yql/core/ut/yql_expr_providers_ut.cpp
@@ -59,9 +59,8 @@ Y_UNIT_TEST_SUITE(TCompileWithProvidersYqlExpr) {
         auto yqlNativeServices = NFile::TYtFileServices::Make(functionRegistry.Get(), testTables);
         auto ytGateway = CreateYtFileGateway(yqlNativeServices);
         auto typeAnnotationContext = MakeIntrusive<TTypeAnnotationContext>();
-        auto ytState = MakeIntrusive<TYtState>();
+        auto ytState = MakeIntrusive<TYtState>(typeAnnotationContext.Get());
         ytState->Gateway = ytGateway;
-        ytState->Types = typeAnnotationContext.Get();
 
         InitializeYtGateway(ytGateway, ytState);
         typeAnnotationContext->AddDataSink(YtProviderName, CreateYtDataSink(ytState));
diff --git 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<IGraphTransformer::TStatus, TAsyncTransformCallbackFuture> 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<std::function<TUserDataTable()>>& completedFuture) {
                 return TAsyncTransformCallback([completedFuture](const TExprNode::TPtr& input, TExprNode::TPtr& output, TExprContext& ctx) {
diff --git a/ydb/library/yql/providers/yt/common/yql_yt_settings.cpp b/ydb/library/yql/providers/yt/common/yql_yt_settings.cpp
@@ -54,7 +54,7 @@ void MediaValidator(const NYT::TNode& value) {
     }
 }
 
-TYtConfiguration::TYtConfiguration()
+TYtConfiguration::TYtConfiguration(TTypeAnnotationContext& typeCtx)
 {
     const auto codecValidator = [] (const TString&, TString str) {
         if (!ValidateCompressionCodecValue(str)) {
@@ -188,7 +188,7 @@ TYtConfiguration::TYtConfiguration()
             }
         });
     REGISTER_SETTING(*this, ExpirationDeadline)
-        .Lower(Now())
+        .Lower(typeCtx.QContext.CanRead() ? TInstant::Zero() : Now())
         .ValueSetter([this] (const TString& cluster, TInstant value) {
             ExpirationDeadline[cluster] = value;
         });
diff --git a/ydb/library/yql/providers/yt/common/yql_yt_settings.h b/ydb/library/yql/providers/yt/common/yql_yt_settings.h
@@ -295,7 +295,7 @@ inline TString GetTablesTmpFolder(const TYtSettings& settings) {
 struct TYtConfiguration : public TYtSettings, public NCommon::TSettingDispatcher {
     using TPtr = TIntrusivePtr<TYtConfiguration>;
 
-    TYtConfiguration();
+    TYtConfiguration(TTypeAnnotationContext& typeCtx);
     TYtConfiguration(const TYtConfiguration&) = delete;
 
     template <class TProtoConfig, typename TFilter>
@@ -336,7 +336,11 @@ class TYtVersionedConfiguration: public TYtConfiguration {
         TYtSettings::TConstPtr Snapshot;
     };
 
-    TYtVersionedConfiguration() = default;
+    TYtVersionedConfiguration(TTypeAnnotationContext& types)
+        : TYtConfiguration(types)
+    {
+    }
+    
     ~TYtVersionedConfiguration() = default;
 
     size_t FindNodeVer(const TExprNode& node);
diff --git a/ydb/library/yql/providers/yt/gateway/native/ut/yql_yt_native_folders_ut.cpp b/ydb/library/yql/providers/yt/gateway/native/ut/yql_yt_native_folders_ut.cpp
@@ -185,14 +185,14 @@ class TYtReplier : public TRequestReplier {
 
 Y_UNIT_TEST_SUITE(YtNativeGateway) {
     
-std::pair<TIntrusivePtr<TYtState>, IYtGateway::TPtr> InitTest(const NTesting::TPortHolder& port) {
+std::pair<TIntrusivePtr<TYtState>, IYtGateway::TPtr> InitTest(const NTesting::TPortHolder& port, TTypeAnnotationContext* types) {
     TYtNativeServices nativeServices;
     auto gatewaysConfig = MakeGatewaysConfig(port);
     nativeServices.Config = std::make_shared<TYtGatewayConfig>(gatewaysConfig.GetYt());
     nativeServices.FileStorage = CreateFileStorage(TFileStorageConfig{});
 
     auto ytGateway = CreateYtNativeGateway(nativeServices);
-    auto ytState = MakeIntrusive<TYtState>();
+    auto ytState = MakeIntrusive<TYtState>(types);
     ytState->Gateway = ytGateway;
 
     InitializeYtGateway(ytGateway, ytState);
@@ -206,7 +206,8 @@ TMaybe<std::function<void(const NYT::TNode& request)>> gatewayRequestAssertion,
         [gatewayRequestAssertion, handleList, handleGet] () {return new TYtReplier(handleList, handleGet, gatewayRequestAssertion);}
     };
 
-    auto [ytState, ytGateway] = InitTest(port);
+    TTypeAnnotationContext types;
+    auto [ytState, ytGateway] = InitTest(port, &types);
 
     IYtGateway::TFolderOptions folderOptions = makeFolderOptions(ytState->SessionId);
     auto folderFuture = ytGateway->GetFolder(std::move(folderOptions));
diff --git a/ydb/library/yql/providers/yt/provider/ut/yql_yt_cbo_ut.cpp b/ydb/library/yql/providers/yt/provider/ut/yql_yt_cbo_ut.cpp
@@ -61,11 +61,10 @@ Y_UNIT_TEST_SUITE(TYqlCBO) {
 
 Y_UNIT_TEST(OrderJoinsDoesNothingWhenCBODisabled) {
     const TString cluster("ut_cluster");
-    TYtState::TPtr state = MakeIntrusive<TYtState>();
+    TTypeAnnotationContext typeCtx;
+    TYtState::TPtr state = MakeIntrusive<TYtState>(&typeCtx);
     TYtJoinNodeOp::TPtr tree = nullptr;
     TYtJoinNodeOp::TPtr optimizedTree;
-    TTypeAnnotationContext typeCtx;
-    state->Types = &typeCtx;
 
     TExprContext ctx;
 
@@ -100,7 +99,8 @@ Y_UNIT_TEST(NonReordable) {
 
 Y_UNIT_TEST(BuildOptimizerTree2Tables) {
     const TString cluster("ut_cluster");
-    TYtState::TPtr state = MakeIntrusive<TYtState>();
+    TTypeAnnotationContext typeCtx;
+    TYtState::TPtr state = MakeIntrusive<TYtState>(&typeCtx);
     TExprContext exprCtx;
     auto tree = MakeOp({"c", "c_nationkey"}, {"n", "n_nationkey"}, {"c", "n"}, exprCtx);
     tree->Left = MakeLeaf({"c"}, {"c"},  100000, 12333, exprCtx);
@@ -127,7 +127,8 @@ Y_UNIT_TEST(BuildOptimizerTree2Tables) {
 
 Y_UNIT_TEST(BuildOptimizerTree2TablesComplexLabel) {
     const TString cluster("ut_cluster");
-    TYtState::TPtr state = MakeIntrusive<TYtState>();
+    TTypeAnnotationContext typeCtx;
+    TYtState::TPtr state = MakeIntrusive<TYtState>(&typeCtx);
     TExprContext exprCtx;
     auto tree = MakeOp({"c", "c_nationkey"}, {"n", "n_nationkey"}, {"c", "n", "e"}, exprCtx);
     tree->Left = MakeLeaf({"c"}, {"c"}, 1000000, 1233333, exprCtx);
@@ -154,7 +155,8 @@ Y_UNIT_TEST(BuildOptimizerTree2TablesComplexLabel) {
 
 Y_UNIT_TEST(BuildYtJoinTree2Tables) {
     const TString cluster("ut_cluster");
-    TYtState::TPtr state = MakeIntrusive<TYtState>();
+    TTypeAnnotationContext typeCtx;
+    TYtState::TPtr state = MakeIntrusive<TYtState>(&typeCtx);
     TExprContext exprCtx;
     auto tree = MakeOp({"c", "c_nationkey"}, {"n", "n_nationkey"}, {"c", "n"}, exprCtx);
     tree->Left = MakeLeaf({"c"}, {"c"},  100000, 12333, exprCtx);
@@ -172,7 +174,8 @@ Y_UNIT_TEST(BuildYtJoinTree2Tables) {
 
 Y_UNIT_TEST(BuildYtJoinTree2TablesForceMergeJoib) {
     const TString cluster("ut_cluster");
-    TYtState::TPtr state = MakeIntrusive<TYtState>();
+    TTypeAnnotationContext typeCtx;
+    TYtState::TPtr state = MakeIntrusive<TYtState>(&typeCtx);
     TExprContext exprCtx;
     auto tree = MakeOp({"c", "c_nationkey"}, {"n", "n_nationkey"}, {"c", "n"}, exprCtx);
     tree->Left = MakeLeaf({"c"}, {"c"},  100000, 12333, exprCtx);
@@ -191,7 +194,8 @@ Y_UNIT_TEST(BuildYtJoinTree2TablesForceMergeJoib) {
 
 Y_UNIT_TEST(BuildYtJoinTree2TablesComplexLabel) {
     const TString cluster("ut_cluster");
-    TYtState::TPtr state = MakeIntrusive<TYtState>();
+    TTypeAnnotationContext typeCtx;
+    TYtState::TPtr state = MakeIntrusive<TYtState>(&typeCtx);
     TExprContext exprCtx;
     auto tree = MakeOp({"c", "c_nationkey"}, {"n", "n_nationkey"}, {"c", "n", "e"}, exprCtx);
     tree->Left = MakeLeaf({"c"}, {"c"}, 1000000, 1233333, exprCtx);
@@ -209,7 +213,8 @@ Y_UNIT_TEST(BuildYtJoinTree2TablesComplexLabel) {
 Y_UNIT_TEST(BuildYtJoinTree2TablesTableIn2Rels)
 {
     const TString cluster("ut_cluster");
-    TYtState::TPtr state = MakeIntrusive<TYtState>();
+    TTypeAnnotationContext typeCtx;
+    TYtState::TPtr state = MakeIntrusive<TYtState>(&typeCtx);
     TExprContext exprCtx;
     auto tree = MakeOp({"c", "c_nationkey"}, {"n", "n_nationkey"}, {"c", "n", "c"}, exprCtx);
     tree->Left = MakeLeaf({"c"}, {"c"}, 1000000, 1233333, exprCtx);
@@ -239,10 +244,9 @@ void OrderJoins2Tables(auto optimizerType) {
     tree->Left = MakeLeaf({"c"}, {"c"},  100000, 12333, exprCtx);
     tree->Right = MakeLeaf({"n"}, {"n"}, 1000, 1233, exprCtx);
 
-    TYtState::TPtr state = MakeIntrusive<TYtState>();
     TTypeAnnotationContext typeCtx;
     typeCtx.CostBasedOptimizer = optimizerType;
-    state->Types = &typeCtx;
+    TYtState::TPtr state = MakeIntrusive<TYtState>(&typeCtx);
     auto optimizedTree = OrderJoins(tree, state, cluster, exprCtx, true);
     UNIT_ASSERT(optimizedTree != tree);
     UNIT_ASSERT(optimizedTree->Left);
@@ -269,9 +273,8 @@ void OrderJoins2TablesComplexLabel(auto optimizerType)
     tree->Right = MakeLeaf({"n"}, {"n", "e"}, 10000, 12333, exprCtx);
 
     TTypeAnnotationContext typeCtx;
-    TYtState::TPtr state = MakeIntrusive<TYtState>();
     typeCtx.CostBasedOptimizer = optimizerType;
-    state->Types = &typeCtx;
+    TYtState::TPtr state = MakeIntrusive<TYtState>(&typeCtx);
     auto optimizedTree = OrderJoins(tree, state, cluster, exprCtx, true);
     UNIT_ASSERT(optimizedTree != tree);
 }
@@ -287,9 +290,8 @@ void OrderJoins2TablesTableIn2Rels(auto optimizerType)
     tree->Right = MakeLeaf({"n"}, {"n", "c"}, 10000, 12333, exprCtx);
 
     TTypeAnnotationContext typeCtx;
-    TYtState::TPtr state = MakeIntrusive<TYtState>();
     typeCtx.CostBasedOptimizer = optimizerType;
-    state->Types = &typeCtx;
+    TYtState::TPtr state = MakeIntrusive<TYtState>(&typeCtx);
     auto optimizedTree = OrderJoins(tree, state, cluster, exprCtx, true);
     UNIT_ASSERT(optimizedTree != tree);
 }
@@ -306,9 +308,8 @@ Y_UNIT_TEST(OrderLeftJoin)
     tree->JoinKind = exprCtx.NewAtom(exprCtx.AppendPosition({}), "Left");
 
     TTypeAnnotationContext typeCtx;
-    TYtState::TPtr state = MakeIntrusive<TYtState>();
     typeCtx.CostBasedOptimizer = ECostBasedOptimizerType::PG;
-    state->Types = &typeCtx;
+    TYtState::TPtr state = MakeIntrusive<TYtState>(&typeCtx);
     auto optimizedTree = OrderJoins(tree, state, cluster, exprCtx, true);
     UNIT_ASSERT(optimizedTree != tree);
     UNIT_ASSERT_STRINGS_EQUAL("Left", optimizedTree->JoinKind->Content());
@@ -324,9 +325,8 @@ Y_UNIT_TEST(UnsupportedJoin)
     tree->JoinKind = exprCtx.NewAtom(exprCtx.AppendPosition({}), "RightSemi");
 
     TTypeAnnotationContext typeCtx;
-    TYtState::TPtr state = MakeIntrusive<TYtState>();
     typeCtx.CostBasedOptimizer = ECostBasedOptimizerType::PG;
-    state->Types = &typeCtx;
+    TYtState::TPtr state = MakeIntrusive<TYtState>(&typeCtx);
     auto optimizedTree = OrderJoins(tree, state, cluster, exprCtx, true);
     UNIT_ASSERT(optimizedTree == tree);
 }
@@ -340,9 +340,8 @@ Y_UNIT_TEST(OrderJoinSinglePass) {
     tree->JoinKind = exprCtx.NewAtom(exprCtx.AppendPosition({}), "Left");
 
     TTypeAnnotationContext typeCtx;
-    TYtState::TPtr state = MakeIntrusive<TYtState>();
     typeCtx.CostBasedOptimizer = ECostBasedOptimizerType::PG;
-    state->Types = &typeCtx;
+    TYtState::TPtr state = MakeIntrusive<TYtState>(&typeCtx);
     auto optimizedTree = OrderJoins(tree, state, cluster, exprCtx, true);
     UNIT_ASSERT(optimizedTree != tree);
     UNIT_ASSERT(optimizedTree->CostBasedOptPassed);
@@ -358,9 +357,8 @@ Y_UNIT_TEST(OrderJoinsDoesNothingWhenCBOAlreadyPassed) {
     tree->CostBasedOptPassed = true;
 
     TTypeAnnotationContext typeCtx;
-    TYtState::TPtr state = MakeIntrusive<TYtState>();
     typeCtx.CostBasedOptimizer = ECostBasedOptimizerType::PG;
-    state->Types = &typeCtx;
+    TYtState::TPtr state = MakeIntrusive<TYtState>(&typeCtx);
     auto optimizedTree = OrderJoins(tree, state, cluster, exprCtx, true);
     UNIT_ASSERT(optimizedTree == tree);
 }
diff --git a/ydb/library/yql/providers/yt/provider/ut/yql_yt_dq_integration_ut.cpp b/ydb/library/yql/providers/yt/provider/ut/yql_yt_dq_integration_ut.cpp
@@ -10,11 +10,9 @@ namespace {
 struct TTestSetup {
     TTestSetup()
         : TypesCtx(MakeHolder<TTypeAnnotationContext>())
-        , State(MakeIntrusive<TYtState>())
+        , State(MakeIntrusive<TYtState>(TypesCtx.Get()))
     {
-        State->Types = TypesCtx.Get();
         State->DqIntegration_ = CreateYtDqIntegration(State.Get());
-
     }
 
     THolder<TTypeAnnotationContext> TypesCtx;
diff --git a/ydb/library/yql/providers/yt/provider/ut/yql_yt_epoch_ut.cpp b/ydb/library/yql/providers/yt/provider/ut/yql_yt_epoch_ut.cpp
@@ -43,9 +43,8 @@ Y_UNIT_TEST_SUITE(TYqlEpoch) {
         auto ytGateway = CreateYtFileGateway(yqlNativeServices);
         auto typeAnnotationContext = MakeIntrusive<TTypeAnnotationContext>();
         typeAnnotationContext->RandomProvider = CreateDeterministicRandomProvider(1);
-        auto ytState = MakeIntrusive<TYtState>();
+        auto ytState = MakeIntrusive<TYtState>(typeAnnotationContext.Get());
         ytState->Gateway = ytGateway;
-        ytState->Types = typeAnnotationContext.Get();
         ytState->Configuration->Dispatch(NCommon::ALL_CLUSTERS, "_EnableWriteReorder", "true", NCommon::TSettingDispatcher::EStage::CONFIG, NCommon::TSettingDispatcher::GetDefaultErrorCallback());
 
         InitializeYtGateway(ytGateway, ytState);
diff --git a/ydb/library/yql/providers/yt/provider/yql_yt_provider.cpp b/ydb/library/yql/providers/yt/provider/yql_yt_provider.cpp
@@ -337,10 +337,9 @@ void TYtState::LeaveEvaluation(ui64 id) {
 }
 
 std::pair<TIntrusivePtr<TYtState>, TStatWriter> CreateYtNativeState(IYtGateway::TPtr gateway, const TString& userName, const TString& sessionId, const TYtGatewayConfig* ytGatewayConfig, TIntrusivePtr<TTypeAnnotationContext> typeCtx) {
-    auto ytState = MakeIntrusive<TYtState>();
+    auto ytState = MakeIntrusive<TYtState>(typeCtx.Get());
     ytState->SessionId = sessionId;
     ytState->Gateway = gateway;
-    ytState->Types = typeCtx.Get();
     ytState->DqIntegration_ = CreateYtDqIntegration(ytState.Get());
 
     if (ytGatewayConfig) {
diff --git a/ydb/library/yql/providers/yt/provider/yql_yt_provider.h b/ydb/library/yql/providers/yt/provider/yql_yt_provider.h
@@ -89,13 +89,18 @@ struct TYtState : public TThrRefBase {
     bool IsHybridEnabled() const;
     bool IsHybridEnabledForCluster(const std::string_view& cluster) const;
     bool HybridTakesTooLong() const;
+    
+    TYtState(TTypeAnnotationContext* types) {
+        Types = types;
+        Configuration = MakeIntrusive<TYtVersionedConfiguration>(*types);
+    }
 
     TString SessionId;
     IYtGateway::TPtr Gateway;
     TTypeAnnotationContext* Types = nullptr;
     TMaybe<std::pair<ui32, size_t>> LoadEpochMetadata; // Epoch being committed, settings versions
     THashMap<ui32, TSet<std::pair<TString, TString>>> EpochDependencies; // List of tables, which have to be updated after committing specific epoch
-    TYtVersionedConfiguration::TPtr Configuration = MakeIntrusive<TYtVersionedConfiguration>();
+    TYtVersionedConfiguration::TPtr Configuration;
     TYtTablesData::TPtr TablesData = MakeIntrusive<TYtTablesData>();
     THashMap<std::pair<TString, TString>, TString> AnonymousLabels; // cluster + label -> name
     std::unordered_map<ui64, TString> NodeHash; // unique id -> hash

Original file line number	Diff line number	Diff line change
`@@ -54,7 +54,7 @@ void MediaValidator(const NYT::TNode& value) {`
`54`	`54`	`}`
`55`	`55`	`}`
`56`	`56`
`57`		`-TYtConfiguration::TYtConfiguration()`
	`57`	`+TYtConfiguration::TYtConfiguration(TTypeAnnotationContext& typeCtx)`
`58`	`58`	`{`
`59`	`59`	`const auto codecValidator = [] (const TString&, TString str) {`
`60`	`60`	`if (!ValidateCompressionCodecValue(str)) {`
`@@ -188,7 +188,7 @@ TYtConfiguration::TYtConfiguration()`
`188`	`188`	`}`
`189`	`189`	`});`
`190`	`190`	`REGISTER_SETTING(*this, ExpirationDeadline)`
`191`		`- .Lower(Now())`
	`191`	`+ .Lower(typeCtx.QContext.CanRead() ? TInstant::Zero() : Now())`
`192`	`192`	`.ValueSetter([this] (const TString& cluster, TInstant value) {`
`193`	`193`	`ExpirationDeadline[cluster] = value;`
`194`	`194`	`});`