home-assistant/core
1
0
Fork 1
mirror of https://github.com/home-assistant/core.git synced 2025-08-15 18:41:44 +02:00
Code Issues Packages Projects Releases Wiki Activity

ruff

Browse Source
This commit is contained in:
jbouwh
2024-05-13 10:41:46 +00:00
parent ffa0dbfc0f
commit d91de41dc1
1 changed files with 4 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
homeassistant/components/mqtt/discovery.py
View File

@@ -226,7 +226,7 @@ def _valid_origin_info(discovery_payload: MQTTDiscoveryPayload) -> bool:
return True return True
try: try:
MQTT_ORIGIN_INFO_SCHEMA(discovery_payload[CONF_ORIGIN]) MQTT_ORIGIN_INFO_SCHEMA(discovery_payload[CONF_ORIGIN])
except Exception as exc: # pylint: disable=broad-except except Exception as exc: # noqa:BLE001
_LOGGER.warning( _LOGGER.warning(
"Unable to parse origin information " "from discovery message: %s, got %s", "Unable to parse origin information " "from discovery message: %s, got %s",
exc, exc,
@@ -317,7 +317,7 @@ async def async_start( # noqa: C901
for component_id, config in component_configs.items(): for component_id, config in component_configs.items():
component = config.pop(CONF_PLATFORM) component = config.pop(CONF_PLATFORM)
component_node_id = ( component_node_id = (
" ".join((component_id, node_id)) if node_id else component_id f"{component_id} {node_id}" if node_id else component_id
) )
_replace_all_abbreviations(config) _replace_all_abbreviations(config)
discovery_payload = MQTTDiscoveryPayload(config) discovery_payload = MQTTDiscoveryPayload(config)
@@ -336,9 +336,7 @@ async def async_start( # noqa: C901
_LOGGER.debug( _LOGGER.debug(
"Process device discovery payload %s", device_discovery_payload "Process device discovery payload %s", device_discovery_payload
) )
device_discovery_id = ( device_discovery_id = f"{node_id} {object_id}" if node_id else object_id
" ".join((node_id, object_id)) if node_id else object_id
)
message = f"Processing device discovery for '{device_discovery_id}'" message = f"Processing device discovery for '{device_discovery_id}'"
async_log_discovery_origin_info( async_log_discovery_origin_info(
message, MQTTDiscoveryPayload(device_discovery_payload) message, MQTTDiscoveryPayload(device_discovery_payload)
@@ -373,7 +371,7 @@ async def async_start( # noqa: C901
_replace_topic_base(discovery_payload) _replace_topic_base(discovery_payload)
# If present, the node_id will be included in the discovered object id # If present, the node_id will be included in the discovered object id
discovery_id = " ".join((node_id, object_id)) if node_id else object_id discovery_id = f"{node_id} {object_id}" if node_id else object_id
discovery_hash = (component, discovery_id) discovery_hash = (component, discovery_id)
if discovery_payload: if discovery_payload: