Skip to content

Commit

Permalink
rm default sling translator
Browse files Browse the repository at this point in the history
  • Loading branch information
cmpadden committed Mar 22, 2024
1 parent a94aab1 commit 23c4ebe
Showing 1 changed file with 1 addition and 5 deletions.
Original file line number Diff line number Diff line change
@@ -1,5 +1,4 @@
from dagster_embedded_elt.sling import (
DagsterSlingTranslator,
SlingResource,
sling_assets,
)
Expand All @@ -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():
Expand Down

0 comments on commit 23c4ebe

Please sign in to comment.