Update history tests to use async_add_executor_job (#41526)

pull/41535/head
J. Nick Koston 2020-10-09 01:36:59 -05:00 committed by GitHub
parent 29aea5a66c
commit 68e1c70b14
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 5 deletions

View File

@ -763,7 +763,7 @@ async def test_fetch_period_api(hass, hass_client):
"""Test the fetch period view for history.""" """Test the fetch period view for history."""
await hass.async_add_executor_job(init_recorder_component, hass) await hass.async_add_executor_job(init_recorder_component, hass)
await async_setup_component(hass, "history", {}) await async_setup_component(hass, "history", {})
await hass.async_add_job(hass.data[recorder.DATA_INSTANCE].block_till_done) await hass.async_add_executor_job(hass.data[recorder.DATA_INSTANCE].block_till_done)
client = await hass_client() client = await hass_client()
response = await client.get(f"/api/history/period/{dt_util.utcnow().isoformat()}") response = await client.get(f"/api/history/period/{dt_util.utcnow().isoformat()}")
assert response.status == 200 assert response.status == 200
@ -775,7 +775,7 @@ async def test_fetch_period_api_with_use_include_order(hass, hass_client):
await async_setup_component( await async_setup_component(
hass, "history", {history.DOMAIN: {history.CONF_ORDER: True}} hass, "history", {history.DOMAIN: {history.CONF_ORDER: True}}
) )
await hass.async_add_job(hass.data[recorder.DATA_INSTANCE].block_till_done) await hass.async_add_executor_job(hass.data[recorder.DATA_INSTANCE].block_till_done)
client = await hass_client() client = await hass_client()
response = await client.get(f"/api/history/period/{dt_util.utcnow().isoformat()}") response = await client.get(f"/api/history/period/{dt_util.utcnow().isoformat()}")
assert response.status == 200 assert response.status == 200
@ -785,7 +785,7 @@ async def test_fetch_period_api_with_minimal_response(hass, hass_client):
"""Test the fetch period view for history with minimal_response.""" """Test the fetch period view for history with minimal_response."""
await hass.async_add_executor_job(init_recorder_component, hass) await hass.async_add_executor_job(init_recorder_component, hass)
await async_setup_component(hass, "history", {}) await async_setup_component(hass, "history", {})
await hass.async_add_job(hass.data[recorder.DATA_INSTANCE].block_till_done) await hass.async_add_executor_job(hass.data[recorder.DATA_INSTANCE].block_till_done)
client = await hass_client() client = await hass_client()
response = await client.get( response = await client.get(
f"/api/history/period/{dt_util.utcnow().isoformat()}?minimal_response" f"/api/history/period/{dt_util.utcnow().isoformat()}?minimal_response"
@ -797,7 +797,7 @@ async def test_fetch_period_api_with_no_timestamp(hass, hass_client):
"""Test the fetch period view for history with no timestamp.""" """Test the fetch period view for history with no timestamp."""
await hass.async_add_executor_job(init_recorder_component, hass) await hass.async_add_executor_job(init_recorder_component, hass)
await async_setup_component(hass, "history", {}) await async_setup_component(hass, "history", {})
await hass.async_add_job(hass.data[recorder.DATA_INSTANCE].block_till_done) await hass.async_add_executor_job(hass.data[recorder.DATA_INSTANCE].block_till_done)
client = await hass_client() client = await hass_client()
response = await client.get("/api/history/period") response = await client.get("/api/history/period")
assert response.status == 200 assert response.status == 200
@ -816,7 +816,7 @@ async def test_fetch_period_api_with_include_order(hass, hass_client):
} }
}, },
) )
await hass.async_add_job(hass.data[recorder.DATA_INSTANCE].block_till_done) await hass.async_add_executor_job(hass.data[recorder.DATA_INSTANCE].block_till_done)
client = await hass_client() client = await hass_client()
response = await client.get( response = await client.get(
f"/api/history/period/{dt_util.utcnow().isoformat()}", f"/api/history/period/{dt_util.utcnow().isoformat()}",