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 b90812a408070..3c7c41fca98e9 100644 --- a/python_modules/libraries/dagster-airbyte/dagster_airbyte/resources.py +++ b/python_modules/libraries/dagster-airbyte/dagster_airbyte/resources.py @@ -1257,9 +1257,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: