jeans/core
jeans/core
1
0
Fork 0
mirror of https://github.com/home-assistant/core.git synced 2025-07-19 19:27:45 +00:00
Code Issues Packages Projects Releases Wiki Activity

Bump aiokafka to 0.10.0 (#108165)

Browse Source
This commit is contained in:
Aaron Bach 2024-01-16 15:16:31 -07:00 committed by GitHub
parent d82abd93fb
commit 25f4fe4a85
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
6 changed files with 6 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
homeassistant/components/apache_kafka/__init__.py
View File

@ -3,9 +3,9 @@ from __future__ import annotations
from datetime import datetime from datetime import datetime
import json import json
import sys
from typing import Any, Literal from typing import Any, Literal
from aiokafka import AIOKafkaProducer
import voluptuous as vol import voluptuous as vol
from homeassistant.const import ( from homeassistant.const import (
@ -19,17 +19,12 @@ from homeassistant.const import (
STATE_UNKNOWN, STATE_UNKNOWN,
) )
from homeassistant.core import Event, HomeAssistant from homeassistant.core import Event, HomeAssistant
from homeassistant.exceptions import HomeAssistantError
import homeassistant.helpers.config_validation as cv import homeassistant.helpers.config_validation as cv
from homeassistant.helpers.entityfilter import FILTER_SCHEMA, EntityFilter from homeassistant.helpers.entityfilter import FILTER_SCHEMA, EntityFilter
from homeassistant.helpers.event import EventStateChangedData from homeassistant.helpers.event import EventStateChangedData
from homeassistant.helpers.typing import ConfigType, EventType from homeassistant.helpers.typing import ConfigType, EventType
from homeassistant.util import ssl as ssl_util from homeassistant.util import ssl as ssl_util
if sys.version_info < (3, 12):
from aiokafka import AIOKafkaProducer
DOMAIN = "apache_kafka" DOMAIN = "apache_kafka"
CONF_FILTER = "filter" CONF_FILTER = "filter"
@ -58,10 +53,6 @@ CONFIG_SCHEMA = vol.Schema(
async def async_setup(hass: HomeAssistant, config: ConfigType) -> bool: async def async_setup(hass: HomeAssistant, config: ConfigType) -> bool:
"""Activate the Apache Kafka integration.""" """Activate the Apache Kafka integration."""
if sys.version_info >= (3, 12):
raise HomeAssistantError(
"Apache Kafka is not supported on Python 3.12. Please use Python 3.11."
)
conf = config[DOMAIN] conf = config[DOMAIN]
kafka = hass.data[DOMAIN] = KafkaManager( kafka = hass.data[DOMAIN] = KafkaManager(

2
homeassistant/components/apache_kafka/manifest.json
View File

@ -5,5 +5,5 @@
"documentation": "https://www.home-assistant.io/integrations/apache_kafka", "documentation": "https://www.home-assistant.io/integrations/apache_kafka",
"iot_class": "local_push", "iot_class": "local_push",
"loggers": ["aiokafka", "kafka_python"], "loggers": ["aiokafka", "kafka_python"],
"requirements": ["aiokafka==0.7.2"] "requirements": ["aiokafka==0.10.0"]
} }

2
requirements_all.txt
View File

@ -276,7 +276,7 @@ aiohue==4.7.0
aioimaplib==1.0.1 aioimaplib==1.0.1
# homeassistant.components.apache_kafka # homeassistant.components.apache_kafka
aiokafka==0.7.2 aiokafka==0.10.0
# homeassistant.components.kef # homeassistant.components.kef
aiokef==0.2.16 aiokef==0.2.16

2
requirements_test_all.txt
View File

@ -252,7 +252,7 @@ aiohue==4.7.0
aioimaplib==1.0.1 aioimaplib==1.0.1
# homeassistant.components.apache_kafka # homeassistant.components.apache_kafka
aiokafka==0.7.2 aiokafka==0.10.0
# homeassistant.components.lifx # homeassistant.components.lifx
aiolifx-effects==0.3.2 aiolifx-effects==0.3.2

5
tests/components/apache_kafka/conftest.py
View File

@ -1,5 +0,0 @@
"""Skip test collection."""
import sys
if sys.version_info >= (3, 12):
collect_ignore_glob = ["test_*.py"]

4
tests/components/apache_kafka/test_init.py
View File

@ -62,7 +62,7 @@ async def test_minimal_config(
config = {apache_kafka.DOMAIN: MIN_CONFIG} config = {apache_kafka.DOMAIN: MIN_CONFIG}
assert await async_setup_component(hass, apache_kafka.DOMAIN, config) assert await async_setup_component(hass, apache_kafka.DOMAIN, config)
await hass.async_block_till_done() await hass.async_block_till_done()
assert mock_client.start.called_once mock_client.start.assert_called_once()
async def test_full_config(hass: HomeAssistant, mock_client: MockKafkaClient) -> None: async def test_full_config(hass: HomeAssistant, mock_client: MockKafkaClient) -> None:
@ -83,7 +83,7 @@ async def test_full_config(hass: HomeAssistant, mock_client: MockKafkaClient) ->
assert await async_setup_component(hass, apache_kafka.DOMAIN, config) assert await async_setup_component(hass, apache_kafka.DOMAIN, config)
await hass.async_block_till_done() await hass.async_block_till_done()
assert mock_client.start.called_once mock_client.start.assert_called_once()
async def _setup(hass, filter_config): async def _setup(hass, filter_config):