import esphome.codegen as cg mqtt_subscribe_ns = cg.esphome_ns.namespace("mqtt_subscribe")