tests/fq/generic/streaming/test_join: dump counters in debug mode

ydb-platform · Oct 10, 2024 · d0208d1 · d0208d1
1 parent 870207c
commit d0208d1
Showing 1 changed file with 9 additions and 0 deletions.
diff --git 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)