diff --git a/kwollect/kwollector_wattmetre.py b/kwollect/kwollector_wattmetre.py
index 97e8e26e3ca4039c9a82d23b07585349197fb589..f263857f16d2905edc8c521e331e76ab964ece92 100755
--- a/kwollect/kwollector_wattmetre.py
+++ b/kwollect/kwollector_wattmetre.py
@@ -149,7 +149,7 @@ def insert_values(values_to_insert):
 def get_highfreq_node():
     try:
         sql_cur.execute(
-            "SELECT DISTINCT device_id FROM promoted_metrics WHERE 'wattmetre_power_watt' ~ metric_id"
+            "SELECT DISTINCT device_id FROM promoted_metrics WHERE regexp_match('wattmetre_power_watt', metric_id, 'b') IS NOT NULL"
         )
         sql_conn.commit()
         return [row[0] for row in sql_cur.fetchall()]