diff --git a/python_modules/libraries/dagster-airbyte/dagster_airbyte/resources.py b/python_modules/libraries/dagster-airbyte/dagster_airbyte/resources.py index 712e0b384e364..62dc4adce80f3 100644 --- a/python_modules/libraries/dagster-airbyte/dagster_airbyte/resources.py +++ b/python_modules/libraries/dagster-airbyte/dagster_airbyte/resources.py @@ -25,8 +25,8 @@ from pydantic import Field, PrivateAttr from requests.exceptions import RequestException -from dagster_airbyte.types import AirbyteOutput from dagster_airbyte.translator import AirbyteWorkspaceData +from dagster_airbyte.types import AirbyteOutput DEFAULT_POLL_INTERVAL_SECONDS = 10 diff --git a/python_modules/libraries/dagster-airbyte/dagster_airbyte/translator.py b/python_modules/libraries/dagster-airbyte/dagster_airbyte/translator.py index c0d500cc91eec..c6a7594c0230b 100644 --- a/python_modules/libraries/dagster-airbyte/dagster_airbyte/translator.py +++ b/python_modules/libraries/dagster-airbyte/dagster_airbyte/translator.py @@ -1,13 +1,12 @@ from typing import Any, Mapping, NamedTuple -from dagster._record import record from dagster._annotations import experimental from dagster._core.definitions.asset_spec import AssetSpec +from dagster._record import record from dagster._serdes.serdes import whitelist_for_serdes -class AirbyteConnectionTableProps(NamedTuple): - ... +class AirbyteConnectionTableProps(NamedTuple): ... @whitelist_for_serdes @@ -17,8 +16,8 @@ class AirbyteConnection: @classmethod def from_connection_details( - cls, - connection_details: Mapping[str, Any], + cls, + connection_details: Mapping[str, Any], ) -> "AirbyteConnection": raise NotImplementedError() @@ -30,8 +29,8 @@ class AirbyteDestination: @classmethod def from_destination_details( - cls, - destination_details: Mapping[str, Any], + cls, + destination_details: Mapping[str, Any], ) -> "AirbyteDestination": raise NotImplementedError()