diff --git a/JciHitachi/aws_connection.py b/JciHitachi/aws_connection.py index 2943f59..f89d3ca 100644 --- a/JciHitachi/aws_connection.py +++ b/JciHitachi/aws_connection.py @@ -76,16 +76,13 @@ def __init__(self, print_response: bool): self._print_response = print_response @abstractmethod - def _generate_headers(self): - ... + def _generate_headers(self): ... @abstractmethod - def _handle_response(self, response: httpx.Response): - ... + def _handle_response(self, response: httpx.Response): ... @abstractmethod - def _send(self): - ... + def _send(self): ... def get_data(self): raise NotImplementedError @@ -597,9 +594,9 @@ def _on_publish(self, topic: str, payload: bytes, dup, qos, retain, **kwargs): ) self._mqtt_events.device_status_event[thing_name].set() elif split_topic[2] == "registration" and split_topic[3] == "response": - self._mqtt_events.device_support[ - thing_name - ] = JciHitachiAWSStatusSupport(payload) + self._mqtt_events.device_support[thing_name] = ( + JciHitachiAWSStatusSupport(payload) + ) self._mqtt_events.device_support_event[thing_name].set() elif split_topic[2] == "control" and split_topic[3] == "response": self._mqtt_events.device_control[thing_name] = payload diff --git a/tests/test_aws_connection.py b/tests/test_aws_connection.py index 51b1009..8729431 100644 --- a/tests/test_aws_connection.py +++ b/tests/test_aws_connection.py @@ -491,9 +491,9 @@ def mock_post_func( "Accept": "application/json", } if test_class.__name__ not in self.no_need_access_token: - h[ - "accesstoken" - ] = f"Bearer {fixture_aws_tokens.access_token}" + h["accesstoken"] = ( + f"Bearer {fixture_aws_tokens.access_token}" + ) assert ( endpoint == f"https://{AWS_IOT_ENDPOINT}/{c.__class__.__name__}"