From d0208d135537dc42be0a9f529e237404bce6bc67 Mon Sep 17 00:00:00 2001 From: Yuriy Kaminskiy Date: Thu, 10 Oct 2024 13:28:50 +0300 Subject: [PATCH] tests/fq/generic/streaming/test_join: dump counters in debug mode --- ydb/tests/fq/generic/streaming/test_join.py | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/ydb/tests/fq/generic/streaming/test_join.py b/ydb/tests/fq/generic/streaming/test_join.py index 476f5dfef598..a911ebb6c4cf 100644 --- a/ydb/tests/fq/generic/streaming/test_join.py +++ b/ydb/tests/fq/generic/streaming/test_join.py @@ -508,6 +508,15 @@ def test_streamlookup( messages_ctr = Counter(map(freeze, map(json.loads, map(itemgetter(1), messages)))) assert read_data_ctr == messages_ctr + if DEBUG: + for node_index in kikimr.compute_plane.kikimr_cluster.nodes: + sensors = kikimr.compute_plane.get_sensors(node_index, "dq_tasks").find_sensors(labels={"operation": query_id}, key_label="sensor") + for k in sensors: + for prefix in ("GenericLookup", "StreamLookupTransform", "InputTransform"): + if k.startswith(prefix): + print(f'node[{node_index}].operation[{query_id}].{k} = {sensors[k]}', file=sys.stderr) + break + fq_client.abort_query(query_id) fq_client.wait_query(query_id)