From 4dc0619b360d9ddaa66d075552493592e1b1a85f Mon Sep 17 00:00:00 2001 From: Maxime Armstrong Date: Tue, 3 Dec 2024 14:33:32 -0500 Subject: [PATCH] Lint --- .../dagster-airbyte/dagster_airbyte/translator.py | 8 +++++--- .../experimental/test_asset_specs.py | 6 +++++- 2 files changed, 10 insertions(+), 4 deletions(-) diff --git a/python_modules/libraries/dagster-airbyte/dagster_airbyte/translator.py b/python_modules/libraries/dagster-airbyte/dagster_airbyte/translator.py index aa438d2b9495d..287eeaef15ed2 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(