aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorMaxim Kovalev <maxkovalev@ydb.tech>2024-10-17 11:58:07 +0300
committerGitHub <noreply@github.com>2024-10-17 11:58:07 +0300
commitfd93fab49c54f6bfaf5e480d6d537eb7f2716f64 (patch)
tree86ccce52c3e791a58fa75bb4dd07c1f0f38affe9
parentd5d5380056d1cefa66db888755a58226293e7d83 (diff)
downloadydb-fd93fab49c54f6bfaf5e480d6d537eb7f2716f64.tar.gz
YQL: Improve logs in DQ worker (#10504)
-rw-r--r--ydb/library/yql/tools/dq/worker_job/dq_worker.cpp5
1 files changed, 5 insertions, 0 deletions
diff --git a/ydb/library/yql/tools/dq/worker_job/dq_worker.cpp b/ydb/library/yql/tools/dq/worker_job/dq_worker.cpp
index b07e74a739..8f47c0f67e 100644
--- a/ydb/library/yql/tools/dq/worker_job/dq_worker.cpp
+++ b/ydb/library/yql/tools/dq/worker_job/dq_worker.cpp
@@ -222,6 +222,11 @@ namespace NYql::NDq::NWorker {
auto archive = layerPath.substr(pos+1);
TShellCommand cmd("tar", {"xf", archive, "-C", layerDir});
cmd.Run().Wait();
+ TMaybe<int> exitCode = cmd.GetExitCode();
+ if (!exitCode.Defined() || exitCode != 0) {
+ const TString msg = TStringBuilder() << "'tar' exited with non-zero code, stderr: " << cmd.GetError();
+ YQL_LOG(ERROR) << msg;
+ }
}
} else {
NFs::MakeDirectoryRecursive("mnt/work");