mirror of
https://github.com/home-assistant/core.git
synced 2025-07-20 03:37:07 +00:00
Fix concurrent reloads in yeelight tests (#110911)
This commit is contained in:
parent
2250baab21
commit
b349a466ba
@ -367,14 +367,14 @@ async def test_async_listen_error_late_discovery(
|
|||||||
with _patch_discovery(), patch(f"{MODULE}.AsyncBulb", return_value=mocked_bulb):
|
with _patch_discovery(), patch(f"{MODULE}.AsyncBulb", return_value=mocked_bulb):
|
||||||
await hass.config_entries.async_setup(config_entry.entry_id)
|
await hass.config_entries.async_setup(config_entry.entry_id)
|
||||||
await hass.async_block_till_done()
|
await hass.async_block_till_done()
|
||||||
|
async_fire_time_changed(hass, dt_util.utcnow() + timedelta(minutes=5))
|
||||||
|
await hass.async_block_till_done()
|
||||||
|
|
||||||
assert config_entry.state is ConfigEntryState.SETUP_RETRY
|
assert config_entry.state is ConfigEntryState.SETUP_RETRY
|
||||||
await hass.async_block_till_done()
|
await hass.async_block_till_done()
|
||||||
assert "Waiting for 0x15243f to be discovered" in caplog.text
|
assert "Waiting for 0x15243f to be discovered" in caplog.text
|
||||||
|
|
||||||
with _patch_discovery(), patch(f"{MODULE}.AsyncBulb", return_value=_mocked_bulb()):
|
with _patch_discovery(), patch(f"{MODULE}.AsyncBulb", return_value=_mocked_bulb()):
|
||||||
async_fire_time_changed(hass, dt_util.utcnow() + timedelta(minutes=5))
|
|
||||||
await hass.async_block_till_done()
|
|
||||||
async_fire_time_changed(hass, dt_util.utcnow() + timedelta(minutes=10))
|
async_fire_time_changed(hass, dt_util.utcnow() + timedelta(minutes=10))
|
||||||
await hass.async_block_till_done()
|
await hass.async_block_till_done()
|
||||||
|
|
||||||
@ -398,14 +398,14 @@ async def test_fail_to_fetch_initial_state(
|
|||||||
with _patch_discovery(), patch(f"{MODULE}.AsyncBulb", return_value=mocked_bulb):
|
with _patch_discovery(), patch(f"{MODULE}.AsyncBulb", return_value=mocked_bulb):
|
||||||
await hass.config_entries.async_setup(config_entry.entry_id)
|
await hass.config_entries.async_setup(config_entry.entry_id)
|
||||||
await hass.async_block_till_done()
|
await hass.async_block_till_done()
|
||||||
|
async_fire_time_changed(hass, dt_util.utcnow() + timedelta(minutes=5))
|
||||||
|
await hass.async_block_till_done()
|
||||||
|
|
||||||
assert config_entry.state is ConfigEntryState.SETUP_RETRY
|
assert config_entry.state is ConfigEntryState.SETUP_RETRY
|
||||||
await hass.async_block_till_done()
|
await hass.async_block_till_done()
|
||||||
assert "Could not fetch initial state; try power cycling the device" in caplog.text
|
assert "Could not fetch initial state; try power cycling the device" in caplog.text
|
||||||
|
|
||||||
with _patch_discovery(), patch(f"{MODULE}.AsyncBulb", return_value=_mocked_bulb()):
|
with _patch_discovery(), patch(f"{MODULE}.AsyncBulb", return_value=_mocked_bulb()):
|
||||||
async_fire_time_changed(hass, dt_util.utcnow() + timedelta(minutes=5))
|
|
||||||
await hass.async_block_till_done()
|
|
||||||
async_fire_time_changed(hass, dt_util.utcnow() + timedelta(minutes=10))
|
async_fire_time_changed(hass, dt_util.utcnow() + timedelta(minutes=10))
|
||||||
await hass.async_block_till_done()
|
await hass.async_block_till_done()
|
||||||
|
|
||||||
@ -483,11 +483,13 @@ async def test_async_setup_with_missing_id(hass: HomeAssistant) -> None:
|
|||||||
await hass.async_block_till_done()
|
await hass.async_block_till_done()
|
||||||
assert config_entry.state is ConfigEntryState.SETUP_RETRY
|
assert config_entry.state is ConfigEntryState.SETUP_RETRY
|
||||||
assert config_entry.data[CONF_ID] == ID
|
assert config_entry.data[CONF_ID] == ID
|
||||||
|
async_fire_time_changed(hass, dt_util.utcnow() + timedelta(minutes=2))
|
||||||
|
await hass.async_block_till_done()
|
||||||
|
|
||||||
with _patch_discovery(), _patch_discovery_timeout(), _patch_discovery_interval(), patch(
|
with _patch_discovery(), _patch_discovery_timeout(), _patch_discovery_interval(), patch(
|
||||||
f"{MODULE}.AsyncBulb", return_value=_mocked_bulb()
|
f"{MODULE}.AsyncBulb", return_value=_mocked_bulb()
|
||||||
):
|
):
|
||||||
async_fire_time_changed(hass, dt_util.utcnow() + timedelta(minutes=2))
|
async_fire_time_changed(hass, dt_util.utcnow() + timedelta(minutes=4))
|
||||||
await hass.async_block_till_done()
|
await hass.async_block_till_done()
|
||||||
assert config_entry.state is ConfigEntryState.LOADED
|
assert config_entry.state is ConfigEntryState.LOADED
|
||||||
|
|
||||||
@ -508,11 +510,13 @@ async def test_async_setup_with_missing_unique_id(hass: HomeAssistant) -> None:
|
|||||||
await hass.async_block_till_done()
|
await hass.async_block_till_done()
|
||||||
assert config_entry.state is ConfigEntryState.SETUP_RETRY
|
assert config_entry.state is ConfigEntryState.SETUP_RETRY
|
||||||
assert config_entry.unique_id == ID
|
assert config_entry.unique_id == ID
|
||||||
|
async_fire_time_changed(hass, dt_util.utcnow() + timedelta(minutes=2))
|
||||||
|
await hass.async_block_till_done()
|
||||||
|
|
||||||
with _patch_discovery(), _patch_discovery_timeout(), _patch_discovery_interval(), patch(
|
with _patch_discovery(), _patch_discovery_timeout(), _patch_discovery_interval(), patch(
|
||||||
f"{MODULE}.AsyncBulb", return_value=_mocked_bulb()
|
f"{MODULE}.AsyncBulb", return_value=_mocked_bulb()
|
||||||
):
|
):
|
||||||
async_fire_time_changed(hass, dt_util.utcnow() + timedelta(minutes=2))
|
async_fire_time_changed(hass, dt_util.utcnow() + timedelta(minutes=4))
|
||||||
await hass.async_block_till_done()
|
await hass.async_block_till_done()
|
||||||
assert config_entry.state is ConfigEntryState.LOADED
|
assert config_entry.state is ConfigEntryState.LOADED
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user