@time_trigger("cron(*/15 * * * *)")
def water_heater():
 level = float(state.get("sensor.hyper_1_electric_level") or 0)
 if level > 98:
 log.info(f"Water Heater ON (level: {level})")
 task.executor(state.set, "light.water_heater_switch", "on")
 elif level < 80:
 log.info(f"Water Heater OFF (level: {level})")
 task.executor(state.set, "light.water_heater_switch", "off")
 else:
 # Check if the current charging speed of the batteries is more than what the water heater would consume.
 # We're only looking at one out of 2 batteries so take that into account
 if float(state.get("sensor.hyper_1_output_pack_power") or 0) > 300/2:
 log.info(f"Water Heater ON PV direct")
 task.executor(state.set, "light.water_heater_switch", "on")

Exception in <file.water_heater.water_heater> line 10: task.executor(state.set, "light.water_heater_switch", "off") ^ RuntimeError: no running event loop