Skip to content

Commit

Permalink
Lint
Browse files Browse the repository at this point in the history
  • Loading branch information
maximearmstrong committed Dec 18, 2024
1 parent 82e6c35 commit 8450ca9
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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(
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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:
Expand Down

0 comments on commit 8450ca9

Please sign in to comment.