From 23c4ebebb0537e46beb4c6bb85fd9878a9ac4b29 Mon Sep 17 00:00:00 2001 From: Colton Padden Date: Fri, 22 Mar 2024 10:33:44 -0400 Subject: [PATCH] rm default sling translator --- .../integrations/embedded_elt/sling_dagster_translator.py | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) 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():