async def async_select_source(self, source):
    'Select input source.'
    if (source not in SOURCES):
        _LOGGER.error('Unsupported source')
        return
    (await self.hass.async_add_job(self.send_key, SOURCES[source]))
Select input source.
async def async_select_source(self, source):
    
    if (source not in SOURCES):
        _LOGGER.error('Unsupported source')
        return
    (await self.hass.async_add_job(self.send_key, SOURCES[source]))