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

Author: yumkam

ydb/tests/fq/generic/streaming/test_join.py

@@ -519,6 +519,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)