aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authoraselutin <aselutin@yandex-team.ru>2022-07-05 00:24:45 +0300
committeraselutin <aselutin@yandex-team.ru>2022-07-05 00:24:45 +0300
commitd7eca02c8b2d879869f924f4fb05a453d4615dae (patch)
tree6d28c8fc07412c08f6210f14502cc5fab4bb014c
parenta1c72572c3819e78645a859233a5c8838c5a2282 (diff)
downloadydb-d7eca02c8b2d879869f924f4fb05a453d4615dae.tar.gz
ydb_recipe: add some fixes to recipe
fix ydb recipes Relates: TAXITOOLS-5084 ref:3168177163117d22eca106046db7267acdf545b5
-rw-r--r--ydb/public/tools/lib/cmds/__init__.py14
1 files changed, 11 insertions, 3 deletions
diff --git a/ydb/public/tools/lib/cmds/__init__.py b/ydb/public/tools/lib/cmds/__init__.py
index ee6ddda8425..da12fbf302b 100644
--- a/ydb/public/tools/lib/cmds/__init__.py
+++ b/ydb/public/tools/lib/cmds/__init__.py
@@ -338,7 +338,10 @@ def deploy(arguments):
def _stop_instances(arguments):
- info = Recipe(arguments).read_metafile()
+ recipe = Recipe(arguments)
+ if not os.path.exists(recipe.metafile_path()):
+ return
+ info = recipe.read_metafile()
for node_id, node_meta in info['nodes'].items():
pid = node_meta['pid']
try:
@@ -356,7 +359,10 @@ def cleanup_working_dir(arguments):
def _cleanup_working_dir(arguments):
- info = Recipe(arguments).read_metafile()
+ recipe = Recipe(arguments)
+ if not os.path.exists(recipe.metafile_path()):
+ return
+ info = recipe.read_metafile()
for node_id, node_meta in info['nodes'].items():
pdisks = node_meta['pdisks']
for pdisk in pdisks:
@@ -421,13 +427,15 @@ def produce_arguments(args):
parser.add_argument("--ydb-working-dir", action="store")
parser.add_argument("--debug-logging", nargs='*')
parser.add_argument("--enable-pq", action='store_true', default=False)
+ parser.add_argument("--fixed-ports", action='store_true', default=False)
parser.add_argument("--pq-client-service-type", action='append', default=[])
parser.add_argument("--enable-datastreams", action='store_true', default=False)
parser.add_argument("--enable-pqcd", action='store_true', default=False)
- parsed, _ = parser.parse_known_args()
+ parsed, _ = parser.parse_known_args(args)
arguments = EmptyArguments()
arguments.suppress_version_check = parsed.suppress_version_check
arguments.ydb_working_dir = parsed.ydb_working_dir
+ arguments.fixed_ports = parsed.fixed_ports
if parsed.use_packages is not None:
arguments.use_packages = parsed.use_packages
if parsed.debug_logging: