Merge pull request #104 from CM000n/Update_questdb_client_to_2.0.4

Update questdb client to 2.0.4

Author: CM000n

custom_components/qss/__init__.py

@@ -50,7 +50,7 @@
         vol.Required(CONF_AUTH_D_KEY, default=""): cv.string,
         vol.Required(CONF_AUTH_X_KEY, default=""): cv.string,
         vol.Required(CONF_AUTH_Y_KEY, default=""): cv.string,
-    },
+    }
 )
 
 
@@ -61,8 +61,8 @@
                 vol.Required(CONF_HOST): cv.string,
                 vol.Required(CONF_PORT): cv.positive_int,
                 vol.Optional(CONF_AUTH, default={}): AUTHENTICATION_SCHEMA,
-            },
-        ),
+            }
+        )
     },
     extra=vol.ALLOW_EXTRA,
 )
@@ -85,11 +85,7 @@ async def async_setup(hass: HomeAssistant, config: ConfigType) -> bool:
     db_auth = (auth_kid, auth_d_key, auth_x_key, auth_y_key, auth_ssl_check)
 
     instance = QuestDB(
-        hass=hass,
-        host=db_host,
-        port=db_port,
-        entity_filter=entity_filter,
-        auth=db_auth,
+        hass=hass, host=db_host, port=db_port, entity_filter=entity_filter, auth=db_auth
     )
     instance.async_initialize()
     instance.start()
@@ -154,8 +150,7 @@ def notify_hass_started(event: Event) -> None:  # noqa: ARG001
                     hass_started.set_result(None)
 
                 self.hass.bus.async_listen_once(
-                    EVENT_HOMEASSISTANT_START,
-                    notify_hass_started,
+                    EVENT_HOMEASSISTANT_START, notify_hass_started
                 )
 
         self.hass.add_job(register)
@@ -168,11 +163,7 @@ def notify_hass_started(event: Event) -> None:  # noqa: ARG001
             event = get_event_from_queue(self.queue)
             finish_task_if_empty_event(event, self.queue)
             insert_event_data_into_questdb(
-                self.host,
-                self.port,
-                self.auth,
-                event,
-                self.queue,
+                self.host, self.port, self.auth, event, self.queue
             )
 
     @callback

custom_components/qss/event_handling.py

@@ -8,15 +8,13 @@
 
 
 def put_event_to_queue(
-    event: Event,
-    entity_filter: Callable[[str], bool],
-    queue: Queue,
+    event: Event, entity_filter: Callable[[str], bool], queue: Queue
 ) -> None:
     """Get events with new states and put them in the process queue."""
     entity_id = event.data.get(ATTR_ENTITY_ID)
     state = event.data.get("new_state")
     if state is not None and all(
-        [entity_id, state, state.state != STATE_UNKNOWN, entity_filter(entity_id)],
+        [entity_id, state, state.state != STATE_UNKNOWN, entity_filter(entity_id)]
     ):
         queue.put(event)
 

custom_components/qss/io.py

@@ -29,9 +29,7 @@ def _insert_row_with_auth(host: str, port: int, auth: tuple, event: Event) -> No
         attrs = dict(state.attributes)
         sender.row(
             "qss",
-            symbols={
-                "entity_id": entity_id,
-            },
+            symbols={"entity_id": entity_id},
             columns={
                 "state": state.state,
                 "attributes": dumps(attrs, sort_keys=True, default=str),
@@ -49,9 +47,7 @@ def _insert_row_without_auth(host: str, port: int, event: Event) -> None:
         attrs = dict(state.attributes)
         sender.row(
             "qss",
-            symbols={
-                "entity_id": entity_id,
-            },
+            symbols={"entity_id": entity_id},
             columns={
                 "state": state.state,
                 "attributes": dumps(attrs, sort_keys=True, default=str),

custom_components/qss/manifest.json

@@ -6,6 +6,6 @@
   "documentation": "https://github.com/CM000n/QSS",
   "iot_class": "local_push",
   "issue_tracker": "https://github.com/CM000n/QSS/issues",
-  "requirements": ["questdb>=2.0.3", "tenacity>=8.0"],
-  "version": "v0.0.15"
+  "requirements": ["questdb>=2.0.4", "tenacity>=9.0"],
+  "version": "v0.0.16"
 }