Fix deprecated ops

dagster-io · Nov 26, 2024 · 71b2b7a · 71b2b7a
1 parent bf49888
commit 71b2b7a
Showing 1 changed file with 12 additions and 12 deletions.
diff --git 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,