diff --git a/python_modules/libraries/dagster-fivetran/dagster_fivetran/ops.py b/python_modules/libraries/dagster-fivetran/dagster_fivetran/ops.py index 439c51bf70d4c..21c7cd8a3adcc 100644 --- a/python_modules/libraries/dagster-fivetran/dagster_fivetran/ops.py +++ b/python_modules/libraries/dagster-fivetran/dagster_fivetran/ops.py @@ -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( @@ -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 @@ -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( @@ -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,