summaryrefslogtreecommitdiffstats
path: root/yt/cpp/mapreduce/interface/serialize.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'yt/cpp/mapreduce/interface/serialize.cpp')
-rw-r--r--yt/cpp/mapreduce/interface/serialize.cpp4
1 files changed, 4 insertions, 0 deletions
diff --git a/yt/cpp/mapreduce/interface/serialize.cpp b/yt/cpp/mapreduce/interface/serialize.cpp
index 28a734a500b..44e168704d7 100644
--- a/yt/cpp/mapreduce/interface/serialize.cpp
+++ b/yt/cpp/mapreduce/interface/serialize.cpp
@@ -482,6 +482,9 @@ void Serialize(const TRichYPath& path, NYson::IYsonConsumer* consumer)
.DoIf(path.Create_.Defined(), [&] (TFluentAttributes fluent) {
fluent.Item("create").Value(*path.Create_);
})
+ .DoIf(path.InputQuery_.Defined(), [&] (TFluentAttributes fluent) {
+ fluent.Item("input_query").Value(*path.InputQuery_);
+ })
.EndAttributes()
.Value(path.Path_);
}
@@ -515,6 +518,7 @@ void Deserialize(TRichYPath& path, const TNode& node)
DESERIALIZE_ATTR("bypass_artifact_cache", path.BypassArtifactCache_);
DESERIALIZE_ATTR("cluster", path.Cluster_);
DESERIALIZE_ATTR("create", path.Create_);
+ DESERIALIZE_ATTR("input_query", path.InputQuery_);
Deserialize(path.Path_, node);
}