diff --git a/examples/docs_snippets/docs_snippets/integrations/embedded_elt/sling_dagster_translator.py b/examples/docs_snippets/docs_snippets/integrations/embedded_elt/sling_dagster_translator.py index e178c63988173..752e9422ff7c1 100644 --- a/examples/docs_snippets/docs_snippets/integrations/embedded_elt/sling_dagster_translator.py +++ b/examples/docs_snippets/docs_snippets/integrations/embedded_elt/sling_dagster_translator.py @@ -1,5 +1,4 @@ from dagster_embedded_elt.sling import ( - DagsterSlingTranslator, SlingResource, sling_assets, ) @@ -10,10 +9,7 @@ sling_resource = SlingResource(connections=[...]) # Add connections here -@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():