Use assignment expressions 14 (#57939)

homeassistant/components/ddwrt/device_tracker.py

@@ -88,9 +88,7 @@ class DdWrtDeviceScanner(DeviceScanner):
             if not data:
                 return None
 
-            dhcp_leases = data.get("dhcp_leases")
+            if not (dhcp_leases := data.get("dhcp_leases")):
-
-            if not dhcp_leases:
                 return None
 
             # Remove leading and trailing quotes and spaces

homeassistant/components/denonavr/config_flow.py

@@ -111,8 +111,7 @@ class DenonAvrFlowHandler(config_entries.ConfigFlow, domain=DOMAIN):
         errors = {}
         if user_input is not None:
             # check if IP address is set manually
-            host = user_input.get(CONF_HOST)
+            if host := user_input.get(CONF_HOST):
-            if host:
                 self.host = host
                 return await self.async_step_connect()
 

homeassistant/components/digital_ocean/binary_sensor.py

@@ -36,8 +36,7 @@ PLATFORM_SCHEMA = PLATFORM_SCHEMA.extend(
 
 def setup_platform(hass, config, add_entities, discovery_info=None):
     """Set up the Digital Ocean droplet sensor."""
-    digital = hass.data.get(DATA_DIGITAL_OCEAN)
+    if not (digital := hass.data.get(DATA_DIGITAL_OCEAN)):
-    if not digital:
         return False
 
     droplets = config[CONF_DROPLETS]

homeassistant/components/digital_ocean/switch.py

@@ -33,8 +33,7 @@ PLATFORM_SCHEMA = PLATFORM_SCHEMA.extend(
 
 def setup_platform(hass, config, add_entities, discovery_info=None):
     """Set up the Digital Ocean droplet switch."""
-    digital = hass.data.get(DATA_DIGITAL_OCEAN)
+    if not (digital := hass.data.get(DATA_DIGITAL_OCEAN)):
-    if not digital:
         return False
 
     droplets = config[CONF_DROPLETS]

homeassistant/components/dovado/notify.py

@@ -22,9 +22,7 @@ class DovadoSMSNotificationService(BaseNotificationService):
 
     def send_message(self, message, **kwargs):
         """Send SMS to the specified target phone number."""
-        target = kwargs.get(ATTR_TARGET)
+        if not (target := kwargs.get(ATTR_TARGET)):
-
-        if not target:
             _LOGGER.error("One target is required")
             return
 

homeassistant/components/econet/water_heater.py

@@ -113,8 +113,7 @@ class EcoNetWaterHeater(EcoNetEntity, WaterHeaterEntity):
 
     def set_temperature(self, **kwargs):
         """Set new target temperature."""
-        target_temp = kwargs.get(ATTR_TEMPERATURE)
+        if (target_temp := kwargs.get(ATTR_TEMPERATURE)) is not None:
-        if target_temp is not None:
             self.water_heater.set_set_point(target_temp)
         else:
             _LOGGER.error("A target temperature must be provided")

homeassistant/components/greeneye_monitor/__init__.py

@@ -157,8 +157,7 @@ async def async_setup(hass, config):
                 }
             )
 
-        sensor_configs = monitor_config[CONF_TEMPERATURE_SENSORS]
+        if sensor_configs := monitor_config[CONF_TEMPERATURE_SENSORS]:
-        if sensor_configs:
             temperature_unit = {
                 CONF_TEMPERATURE_UNIT: sensor_configs[CONF_TEMPERATURE_UNIT]
             }

homeassistant/components/habitica/sensor.py

@@ -213,8 +213,7 @@ class HabitipyTaskSensor(SensorEntity):
                 task_id = received_task[TASKS_MAP_ID]
                 task = {}
                 for map_key, map_value in TASKS_MAP.items():
-                    value = received_task.get(map_value)
+                    if value := received_task.get(map_value):
-                    if value:
                         task[map_key] = value
                 attrs[task_id] = task
             return attrs

homeassistant/components/icloud/__init__.py

@@ -88,9 +88,7 @@ CONFIG_SCHEMA = vol.Schema(
 
 async def async_setup(hass: HomeAssistant, config: ConfigType) -> bool:
     """Set up iCloud from legacy config file."""
-
+    if (conf := config.get(DOMAIN)) is None:
-    conf = config.get(DOMAIN)
-    if conf is None:
         return True
 
     for account_conf in conf:
@@ -169,9 +167,7 @@ async def async_setup_entry(hass: HomeAssistant, entry: ConfigEntry) -> bool:
 
     def update_account(service: ServiceDataType) -> None:
         """Call the update function of an iCloud account."""
-        account = service.data.get(ATTR_ACCOUNT)
+        if (account := service.data.get(ATTR_ACCOUNT)) is None:
-
-        if account is None:
             for account in hass.data[DOMAIN].values():
                 account.keep_alive()
         else:

homeassistant/components/intesishome/climate.py

@@ -259,13 +259,10 @@ class IntesisAC(ClimateEntity):
 
     async def async_set_temperature(self, **kwargs):
         """Set new target temperature."""
-        temperature = kwargs.get(ATTR_TEMPERATURE)
+        if hvac_mode := kwargs.get(ATTR_HVAC_MODE):
-        hvac_mode = kwargs.get(ATTR_HVAC_MODE)
-
-        if hvac_mode:
             await self.async_set_hvac_mode(hvac_mode)
 
-        if temperature:
+        if temperature := kwargs.get(ATTR_TEMPERATURE):
             _LOGGER.debug("Setting %s to %s degrees", self._device_type, temperature)
             await self._controller.set_temperature(self._device_id, temperature)
             self._target_temp = temperature

homeassistant/components/lcn/climate.py

@@ -176,8 +176,7 @@ class LcnClimate(LcnEntity, ClimateEntity):
 
     async def async_set_temperature(self, **kwargs: Any) -> None:
         """Set new target temperature."""
-        temperature = kwargs.get(ATTR_TEMPERATURE)
+        if (temperature := kwargs.get(ATTR_TEMPERATURE)) is None:
-        if temperature is None:
             return
 
         if not await self.device_connection.var_abs(

homeassistant/components/lcn/helpers.py

@@ -208,8 +208,7 @@ def has_unique_host_names(hosts: list[ConfigType]) -> list[ConfigType]:
     """
     suffix = 0
     for host in hosts:
-        host_name = host.get(CONF_NAME)
+        if host.get(CONF_NAME) is None:
-        if host_name is None:
             if suffix == 0:
                 host[CONF_NAME] = DEFAULT_NAME
             else:

homeassistant/components/lcn/services.py

@@ -307,8 +307,7 @@ class SendKeys(LcnServiceCall):
             key_id = int(key) - 1
             keys[table_id][key_id] = True
 
-        delay_time = service.data[CONF_TIME]
+        if (delay_time := service.data[CONF_TIME]) != 0:
-        if delay_time != 0:
             hit = pypck.lcn_defs.SendKeyCommand.HIT
             if pypck.lcn_defs.SendKeyCommand[service.data[CONF_STATE]] != hit:
                 raise ValueError(
@@ -347,8 +346,7 @@ class LockKeys(LcnServiceCall):
         ]
         table_id = ord(service.data[CONF_TABLE]) - 65
 
-        delay_time = service.data[CONF_TIME]
+        if (delay_time := service.data[CONF_TIME]) != 0:
-        if delay_time != 0:
             if table_id != 0:
                 raise ValueError(
                     "Only table A is allowed when locking keys for a specific time."

homeassistant/components/lock/reproduce_state.py

@@ -32,9 +32,7 @@ async def _async_reproduce_state(
     reproduce_options: dict[str, Any] | None = None,
 ) -> None:
     """Reproduce a single state."""
-    cur_state = hass.states.get(state.entity_id)
+    if (cur_state := hass.states.get(state.entity_id)) is None:
-
-    if cur_state is None:
         _LOGGER.warning("Unable to find entity %s", state.entity_id)
         return
 

homeassistant/components/opnsense/device_tracker.py

@@ -56,7 +56,6 @@ class OPNSenseDeviceScanner(DeviceScanner):
         """Return the extra attrs of the given device."""
         if device not in self.last_results:
             return None
-        mfg = self.last_results[device].get("manufacturer")
+        if not (mfg := self.last_results[device].get("manufacturer")):
-        if not mfg:
             return {}
         return {"manufacturer": mfg}

homeassistant/components/owntracks/__init__.py

@@ -242,9 +242,7 @@ class OwnTracksContext:
     @callback
     def async_valid_accuracy(self, message):
         """Check if we should ignore this message."""
-        acc = message.get("acc")
+        if (acc := message.get("acc")) is None:
-
-        if acc is None:
             return False
 
         try:

homeassistant/components/panasonic_viera/__init__.py

@@ -73,8 +73,7 @@ async def async_setup_entry(hass, config_entry):
     host = config[CONF_HOST]
     port = config[CONF_PORT]
 
-    on_action = config[CONF_ON_ACTION]
+    if (on_action := config[CONF_ON_ACTION]) is not None:
-    if on_action is not None:
         on_action = Script(hass, on_action, config[CONF_NAME], DOMAIN)
 
     params = {}

homeassistant/components/risco/alarm_control_panel.py

@@ -164,8 +164,7 @@ class RiscoAlarm(AlarmControlPanelEntity, RiscoEntity):
             _LOGGER.warning("Wrong code entered for %s", mode)
             return
 
-        risco_state = self._ha_to_risco[mode]
+        if not (risco_state := self._ha_to_risco[mode]):
-        if not risco_state:
             _LOGGER.warning("No mapping for mode %s", mode)
             return
 

homeassistant/components/squeezebox/browse_media.py

@@ -97,8 +97,7 @@ async def build_item_response(entity, player, payload):
             item_id = str(item["id"])
             item_thumbnail = None
 
-            artwork_track_id = item.get("artwork_track_id")
+            if artwork_track_id := item.get("artwork_track_id"):
-            if artwork_track_id:
                 if internal_request:
                     item_thumbnail = player.generate_image_url_from_track_id(
                         artwork_track_id

homeassistant/components/squeezebox/media_player.py

@@ -561,8 +561,7 @@ class SqueezeBoxEntity(MediaPlayerEntity):
         player_ids = {
             p.entity_id: p.unique_id for p in self.hass.data[DOMAIN][KNOWN_PLAYERS]
         }
-        other_player_id = player_ids.get(other_player)
+        if other_player_id := player_ids.get(other_player):
-        if other_player_id:
             await self._player.async_sync(other_player_id)
         else:
             _LOGGER.info("Could not find player_id for %s. Not syncing", other_player)

homeassistant/components/telegram_bot/__init__.py

@@ -329,8 +329,7 @@ async def async_setup(hass, config):
         """Handle sending Telegram Bot message service calls."""
 
         def _render_template_attr(data, attribute):
-            attribute_templ = data.get(attribute)
+            if attribute_templ := data.get(attribute):
-            if attribute_templ:
                 if any(
                     isinstance(attribute_templ, vtype) for vtype in (float, int, str)
                 ):

homeassistant/components/xiaomi_aqara/__init__.py

@@ -76,8 +76,7 @@ def setup(hass, config):
 
         kwargs = {"mid": ring_id}
 
-        ring_vol = call.data.get(ATTR_RINGTONE_VOL)
+        if (ring_vol := call.data.get(ATTR_RINGTONE_VOL)) is not None:
-        if ring_vol is not None:
             kwargs["vol"] = ring_vol
 
         gateway.write_to_hub(gateway.sid, **kwargs)
@@ -379,8 +378,7 @@ def _add_gateway_to_schema(hass, schema):
         raise vol.Invalid(f"Unknown gateway sid {sid}")
 
     kwargs = {}
-    xiaomi_data = hass.data.get(DOMAIN)
+    if (xiaomi_data := hass.data.get(DOMAIN)) is not None:
-    if xiaomi_data is not None:
         gateways = list(xiaomi_data[GATEWAYS_KEY].values())
 
         # If the user has only 1 gateway, make it the default for services.

homeassistant/components/xiaomi_aqara/config_flow.py

@@ -76,10 +76,8 @@ class XiaomiAqaraFlowHandler(config_entries.ConfigFlow, domain=DOMAIN):
         if self.host is None:
             self.host = user_input.get(CONF_HOST)
         if self.sid is None:
-            mac_address = user_input.get(CONF_MAC)
-
             # format sid from mac_address
-            if mac_address is not None:
+            if (mac_address := user_input.get(CONF_MAC)) is not None:
                 self.sid = format_mac(mac_address).replace(":", "")
 
         # if host is already known by zeroconf discovery or manual optional settings

homeassistant/components/xiaomi_aqara/lock.py

@@ -22,8 +22,7 @@ async def async_setup_entry(hass, config_entry, async_add_entities):
     entities = []
     gateway = hass.data[DOMAIN][GATEWAYS_KEY][config_entry.entry_id]
     for device in gateway.devices["lock"]:
-        model = device["model"]
+        if device["model"] == "lock.aq1":
-        if model == "lock.aq1":
             entities.append(XiaomiAqaraLock(device, "Lock", gateway, config_entry))
     async_add_entities(entities)
 
@@ -63,14 +62,12 @@ class XiaomiAqaraLock(LockEntity, XiaomiDevice):
 
     def parse_data(self, data, raw_data):
         """Parse data sent by gateway."""
-        value = data.get(VERIFIED_WRONG_KEY)
+        if (value := data.get(VERIFIED_WRONG_KEY)) is not None:
-        if value is not None:
             self._verified_wrong_times = int(value)
             return True
 
         for key in (FINGER_KEY, PASSWORD_KEY, CARD_KEY):
-            value = data.get(key)
+            if (value := data.get(key)) is not None:
-            if value is not None:
                 self._changed_by = int(value)
                 self._verified_wrong_times = 0
                 self._state = STATE_UNLOCKED

homeassistant/components/xiaomi_aqara/sensor.py

@@ -158,8 +158,7 @@ class XiaomiSensor(XiaomiDevice, SensorEntity):
 
     def parse_data(self, data, raw_data):
         """Parse data sent by gateway."""
-        value = data.get(self._data_key)
+        if (value := data.get(self._data_key)) is None:
-        if value is None:
             return False
         if self._data_key in ("coordination", "status"):
             self._attr_native_value = value