diff --git a/python_modules/libraries/dagster-airbyte/dagster_airbyte/translator.py b/python_modules/libraries/dagster-airbyte/dagster_airbyte/translator.py
index ff8bfd08b7109..83c4a5501850d 100644
--- a/python_modules/libraries/dagster-airbyte/dagster_airbyte/translator.py
+++ b/python_modules/libraries/dagster-airbyte/dagster_airbyte/translator.py
@@ -30,10 +30,12 @@ def from_connection_details(
             name=connection_details["name"],
             stream_prefix=connection_details.get("prefix"),
             streams={
-                stream_details["stream"]["name"]: AirbyteStream.from_stream_details(stream_details=stream_details)
+                stream_details["stream"]["name"]: AirbyteStream.from_stream_details(
+                    stream_details=stream_details
+                )
                 for stream_details in connection_details.get("syncCatalog", {}).get("streams", [])
             },
-            destination_id=connection_details["destinationId"]
+            destination_id=connection_details["destinationId"],
         )
 
 
@@ -75,7 +77,7 @@ def from_stream_details(
         return cls(
             name=stream_details["stream"]["name"],
             selected=stream_details["config"].get("selected", False),
-            json_schema=stream_details["stream"].get("jsonSchema", {})
+            json_schema=stream_details["stream"].get("jsonSchema", {}),
         )
 
 
diff --git a/python_modules/libraries/dagster-airbyte/dagster_airbyte_tests/experimental/test_asset_specs.py b/python_modules/libraries/dagster-airbyte/dagster_airbyte_tests/experimental/test_asset_specs.py
index 9da7d019520cc..43a0d5a7cd700 100644
--- a/python_modules/libraries/dagster-airbyte/dagster_airbyte_tests/experimental/test_asset_specs.py
+++ b/python_modules/libraries/dagster-airbyte/dagster_airbyte_tests/experimental/test_asset_specs.py
@@ -1,7 +1,11 @@
 import responses
 from dagster_airbyte import AirbyteCloudWorkspace
 
-from dagster_airbyte_tests.experimental.conftest import TEST_CLIENT_ID, TEST_CLIENT_SECRET, TEST_WORKSPACE_ID
+from dagster_airbyte_tests.experimental.conftest import (
+    TEST_CLIENT_ID,
+    TEST_CLIENT_SECRET,
+    TEST_WORKSPACE_ID,
+)
 
 
 def test_fetch_fivetran_workspace_data(