From 8450ca98a7a658aa286ce2e3969aba3bcbf0b577 Mon Sep 17 00:00:00 2001 From: Maxime Armstrong Date: Tue, 17 Dec 2024 20:19:10 -0500 Subject: [PATCH] Lint --- .../dagster-airbyte/dagster_airbyte/managed/reconciliation.py | 2 +- .../libraries/dagster-airbyte/dagster_airbyte/resources.py | 4 +--- 2 files changed, 2 insertions(+), 4 deletions(-) diff --git a/python_modules/libraries/dagster-airbyte/dagster_airbyte/managed/reconciliation.py b/python_modules/libraries/dagster-airbyte/dagster_airbyte/managed/reconciliation.py index e8f26c16c916b..73adebffb370c 100644 --- a/python_modules/libraries/dagster-airbyte/dagster_airbyte/managed/reconciliation.py +++ b/python_modules/libraries/dagster-airbyte/dagster_airbyte/managed/reconciliation.py @@ -49,7 +49,7 @@ InitializedAirbyteSource, ) from dagster_airbyte.resources import AirbyteResource -from dagster_airbyte.utils import is_basic_normalization_operation, clean_name +from dagster_airbyte.utils import clean_name, is_basic_normalization_operation def gen_configured_stream_json( diff --git a/python_modules/libraries/dagster-airbyte/dagster_airbyte/resources.py b/python_modules/libraries/dagster-airbyte/dagster_airbyte/resources.py index ffbd1d1f4fd26..1e883c3531f36 100644 --- a/python_modules/libraries/dagster-airbyte/dagster_airbyte/resources.py +++ b/python_modules/libraries/dagster-airbyte/dagster_airbyte/resources.py @@ -1258,9 +1258,7 @@ def _generate_materialization( metadata=stream_asset_spec.metadata, ) - def sync_and_poll( - self, context: Union[OpExecutionContext, AssetExecutionContext] - ): + def sync_and_poll(self, context: Union[OpExecutionContext, AssetExecutionContext]): """Executes a sync and poll process to materialize Airbyte Cloud assets. Args: