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 23c4ebe commit 172e14b
Showing 1 changed file with 1 addition and 5 deletions.
6 changes: 1 addition & 5 deletions docs/content/integrations/embedded-elt.mdx
Original file line number Diff line number Diff line change
Expand Up @@ -123,7 +123,6 @@ Each stream will render two assets, one for the source stream and one for the ta

```python file=/integrations/embedded_elt/sling_dagster_translator.py
from dagster_embedded_elt.sling import (
DagsterSlingTranslator,
SlingResource,
sling_assets,
)
Expand All @@ -134,10 +133,7 @@ replication_config = file_relative_path(__file__, "../sling_replication.yaml")
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 172e14b

Please sign in to comment.