rm empty translator usage

dagster-io · Mar 22, 2024 · 1cceda3 · 1cceda3
1 parent f7962b5
commit 1cceda3
Show file tree

Hide file tree

Showing 4 changed files with 5 additions and 24 deletions.
diff --git a/docs/content/integrations/embedded-elt.mdx b/docs/content/integrations/embedded-elt.mdx
@@ -162,7 +162,6 @@ This is an example of how to setup a Sling sync between two databases such as Po
 
 ```python file=/integrations/embedded_elt/postgres_snowflake.py
 from dagster_embedded_elt.sling import (
-    DagsterSlingTranslator,
     SlingConnectionResource,
     SlingResource,
     sling_assets,
@@ -208,10 +207,7 @@ replication_config = {
 }
 
 
-@sling_assets(
-    replication_config=replication_config,
-    dagster_sling_translator=DagsterSlingTranslator(),
-)
+@sling_assets(replication_config=replication_config)
 def my_assets(context, sling: SlingResource):
     yield from sling.replicate(context=context)
 ```
@@ -244,10 +240,7 @@ replication_config = {
 }
 
 
-@sling_assets(
-    replication_config=replication_config,
-    dagster_sling_translator=DagsterSlingTranslator(),
-)
+@sling_assets(replication_config=replication_config)
 def my_assets(context, sling: SlingResource):
     yield from sling.replicate(context=context)
 ```

diff --git a/examples/docs_snippets/docs_snippets/integrations/embedded_elt/postgres_snowflake.py b/examples/docs_snippets/docs_snippets/integrations/embedded_elt/postgres_snowflake.py
@@ -2,7 +2,6 @@
 # pyright: reportOptionalMemberAccess=none
 
 from dagster_embedded_elt.sling import (
-    DagsterSlingTranslator,
     SlingConnectionResource,
     SlingResource,
     sling_assets,
@@ -48,9 +47,6 @@
 }
 
 
-@sling_assets(
-    replication_config=replication_config,
-    dagster_sling_translator=DagsterSlingTranslator(),
-)
+@sling_assets(replication_config=replication_config)
 def my_assets(context, sling: SlingResource):
     yield from sling.replicate(context=context)
diff --git a/examples/docs_snippets/docs_snippets/integrations/embedded_elt/s3_snowflake.py b/examples/docs_snippets/docs_snippets/integrations/embedded_elt/s3_snowflake.py
@@ -2,7 +2,6 @@
 # pyright: reportOptionalMemberAccess=none
 
 from dagster_embedded_elt.sling import (
-    DagsterSlingTranslator,
     SlingConnectionResource,
     SlingResource,
     sling_assets,
@@ -45,10 +44,7 @@
 }
 
 
-@sling_assets(
-    replication_config=replication_config,
-    dagster_sling_translator=DagsterSlingTranslator(),
-)
+@sling_assets(replication_config=replication_config)
 def my_assets(context, sling: SlingResource):
     yield from sling.replicate(context=context)
 

diff --git a/examples/experimental/sling_decorator/sling_decorator/__init__.py b/examples/experimental/sling_decorator/sling_decorator/__init__.py
@@ -1,6 +1,5 @@
 from dagster import Definitions, file_relative_path
 from dagster_embedded_elt.sling import (
-    DagsterSlingTranslator,
     sling_assets,
 )
 from dagster_embedded_elt.sling.resources import (
@@ -26,10 +25,7 @@
 )
 
 
-@sling_assets(
-    replication_config=replication_config,
-    dagster_sling_translator=DagsterSlingTranslator(),
-)
+@sling_assets(replication_config=replication_config)
 def my_assets(context, sling: SlingResource):
     yield from sling.replicate(context=context)
     for row in sling.stream_raw_logs():