From 3cbb541dc69a0bd151ae01d28988102b19f201db Mon Sep 17 00:00:00 2001 From: coteeq Date: Sun, 23 Mar 2025 20:48:26 +0300 Subject: YQL-19214: Check existence only on local cluster commit_hash:7a826081edd81909397bf261cd1c82d7934479a0 --- yt/cpp/mapreduce/client/operation.cpp | 24 +++++++++++++----------- 1 file changed, 13 insertions(+), 11 deletions(-) (limited to 'yt/cpp/mapreduce/client/operation.cpp') diff --git a/yt/cpp/mapreduce/client/operation.cpp b/yt/cpp/mapreduce/client/operation.cpp index 652c01e4be5..4eac765500c 100644 --- a/yt/cpp/mapreduce/client/operation.cpp +++ b/yt/cpp/mapreduce/client/operation.cpp @@ -1062,17 +1062,19 @@ void CheckInputTablesExist( { Y_ENSURE(!paths.empty(), "Input tables are not set"); for (auto& path : paths) { - auto curTransactionId = path.TransactionId_.GetOrElse(preparer.GetTransactionId()); - auto exists = RequestWithRetry( - preparer.GetClientRetryPolicy()->CreatePolicyForGenericRequest(), - [&preparer, &curTransactionId, &path] (TMutationId /*mutationId*/) { - return preparer.GetClient()->GetRawClient()->Exists( - curTransactionId, - path.Path_); - }); - Y_ENSURE_EX( - path.Cluster_.Defined() || exists, - TApiUsageError() << "Input table '" << path.Path_ << "' doesn't exist"); + if (!path.Cluster_.Defined()) { + auto curTransactionId = path.TransactionId_.GetOrElse(preparer.GetTransactionId()); + auto exists = RequestWithRetry( + preparer.GetClientRetryPolicy()->CreatePolicyForGenericRequest(), + [&preparer, &curTransactionId, &path] (TMutationId /*mutationId*/) { + return preparer.GetClient()->GetRawClient()->Exists( + curTransactionId, + path.Path_); + }); + Y_ENSURE_EX( + exists, + TApiUsageError() << "Input table '" << path.Path_ << "' doesn't exist"); + } } } -- cgit v1.3