ACLP Logs Stream - Formatting tweaks

Author: sjer-akamai

linode_api4/objects/monitor.py

@@ -610,14 +610,17 @@ def history(self):
             LogsDestinationHistory
         )
 
+
 class LogsStreamStatus(StrEnum):
     active = "active"
     inactive = "inactive"
     provisioning = "provisioning"
 
+
 class LogsStreamType(StrEnum):
     audit_logs = "audit_logs"
 
+
 @dataclass
 class LogsStreamDestination(JSONObject):
     """
@@ -629,6 +632,7 @@ class LogsStreamDestination(JSONObject):
     type: Optional[LogsDestinationType] = None
     details: Optional[LogsDestinationDetails] = None
 
+
 class LogsStreamHistory(Base):
     """
     Represents a read-only historical snapshot of logs Stream.
@@ -649,6 +653,7 @@ class LogsStreamHistory(Base):
         "version": Property(),
     }
 
+
 class LogsStream(Base):
     """
     Represents a logs stream object.

test/integration/models/monitor/test_monitor_logs.py

@@ -223,7 +223,7 @@ def test_fails_to_create_destination_empty_required_fields(test_linode_client: L
 @pytest.mark.skipif(
     os.getenv(RUN_ACLP_LOGS_STREAM_TESTS, "").strip().lower() not in {"yes", "true"},
     reason=f"{RUN_ACLP_LOGS_STREAM_TESTS} environment variable must be set to 'yes' or 'true'",
-    )
+)
 def test_fails_to_create_stream_invalid_destination(test_linode_client: LinodeClient):
     """
     Test that creating a stream with a non-existent destination ID results in a 400 ApiError.
@@ -264,13 +264,13 @@ def test_stream_create(test_linode_client: LinodeClient, test_destination: LogsD
     send_request_when_resource_available(timeout=100, func=stream.delete)
 
 
-
 @pytest.fixture(scope="session")
 def test_stream_active(test_linode_client: LinodeClient, test_stream_create: LogsStream):
     """
     Waits until the stream transitions out of provisioning state.
     NOTE: Stream provisioning can take up to 60 minutes to finish.
     """
+
     def is_stream_provisioned():
         stream = test_linode_client.load(LogsStream, test_stream_create.id)
         return stream.status in (LogsStreamStatus.active, LogsStreamStatus.inactive)
@@ -352,7 +352,6 @@ def test_update_stream_label(test_linode_client: LinodeClient, test_stream_activ
         updated.save()
 
 
-
 @pytest.mark.skipif(
     os.getenv(RUN_ACLP_LOGS_STREAM_TESTS, "").strip().lower() not in {"yes", "true"},
     reason=f"{RUN_ACLP_LOGS_STREAM_TESTS} environment variable must be set to 'yes' or 'true'",

test/unit/objects/monitor_test.py

@@ -341,6 +341,7 @@ def test_delete_destination(self):
             m.call_url, "/monitor/streams/destinations/1"
         )
 
+
 class LogsStreamTest(ClientBaseCase):
     """
     Tests methods for LogsStream class.
@@ -472,10 +473,10 @@ def test_update_stream_destinations(self):
         stream = self.client.load(LogsStream, 1)
 
         with self.mock_put({}) as m:
-            result = stream.update_destinations([1,2,3])
+            result = stream.update_destinations([1, 2, 3])
 
         self.assertEqual(m.call_url, "/monitor/streams/1")
-        self.assertEqual(m.call_data["destinations"], [1,2,3])
+        self.assertEqual(m.call_data["destinations"], [1, 2, 3])
         self.assertTrue(result)
 
     def test_fail_update_stream_destinations_when_no_destination_ids_passed(self):