Skip to content

Commit

Permalink
Fix deprecated ops
Browse files Browse the repository at this point in the history
  • Loading branch information
maximearmstrong committed Nov 27, 2024
1 parent 5e51073 commit a896446
Showing 1 changed file with 12 additions and 12 deletions.
24 changes: 12 additions & 12 deletions python_modules/libraries/dagster-fivetran/dagster_fivetran/ops.py
Original file line number Diff line number Diff line change
Expand Up @@ -44,12 +44,6 @@ class SyncConfig(Config):
)


@deprecated(
breaking_version="2.0",
additional_warn_text=(
"Fivetran ops will be deprecated. Use `FivetranWorkspace` resource and `@fivetran_asset` decorator instead"
),
)
@op(
ins={"start_after": In(Nothing)},
out=Out(
Expand All @@ -63,6 +57,12 @@ class SyncConfig(Config):
),
tags={COMPUTE_KIND_TAG: "fivetran"},
)
@deprecated(
breaking_version="2.0",
additional_warn_text=(
"Fivetran ops will be deprecated. Use `FivetranWorkspace` resource and `@fivetran_asset` decorator instead"
),
)
def fivetran_sync_op(config: SyncConfig, fivetran: FivetranResource) -> Any:
"""Executes a Fivetran sync for a given ``connector_id``, and polls until that sync
completes, raising an error if it is unsuccessful. It outputs a FivetranOutput which contains
Expand Down Expand Up @@ -119,12 +119,6 @@ class FivetranResyncConfig(SyncConfig):
)


@deprecated(
breaking_version="2.0",
additional_warn_text=(
"Fivetran ops will be deprecated. Use `FivetranWorkspace` resource and `@fivetran_asset` decorator instead"
),
)
@op(
ins={"start_after": In(Nothing)},
out=Out(
Expand All @@ -138,6 +132,12 @@ class FivetranResyncConfig(SyncConfig):
),
tags={COMPUTE_KIND_TAG: "fivetran"},
)
@deprecated(
breaking_version="2.0",
additional_warn_text=(
"Fivetran ops will be deprecated. Use `FivetranWorkspace` resource and `@fivetran_asset` decorator instead"
),
)
def fivetran_resync_op(
config: FivetranResyncConfig,
fivetran: FivetranResource,
Expand Down

0 comments on commit a896446

Please sign in to comment.