diff options
author | Maxim Kovalev <maxkovalev@ydb.tech> | 2024-10-17 11:58:07 +0300 |
---|---|---|
committer | GitHub <noreply@github.com> | 2024-10-17 11:58:07 +0300 |
commit | fd93fab49c54f6bfaf5e480d6d537eb7f2716f64 (patch) | |
tree | 86ccce52c3e791a58fa75bb4dd07c1f0f38affe9 | |
parent | d5d5380056d1cefa66db888755a58226293e7d83 (diff) | |
download | ydb-fd93fab49c54f6bfaf5e480d6d537eb7f2716f64.tar.gz |
YQL: Improve logs in DQ worker (#10504)
-rw-r--r-- | ydb/library/yql/tools/dq/worker_job/dq_worker.cpp | 5 |
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"); |