diff --git a/README.md b/README.md index e6d0cc7..9e6bc18 100644 --- a/README.md +++ b/README.md @@ -2,7 +2,7 @@ [![PyPI version](https://badge.fury.io/py/dagster-ext.svg)](https://badge.fury.io/py/dagster-ext) -This project is still a work in progress. Please create an issue if you find any bugs. +This project uses [`dagster-meltano`](https://github.com/quantile-development/dagster-meltano) under the hood. ## Features @@ -39,54 +39,3 @@ meltano invoke dagster:start ``` Start Dagit to serve your local Dagster deployment. - -## Code Examples - -Below are some code examples how to use the `dagster-meltano` package. - -### Automatically load all jobs and schedules from your Meltano project. - -```python -from dagster import repository - -from dagster_meltano import load_jobs_from_meltano_project - -meltano_jobs = load_jobs_from_meltano_project("") - -@repository -def repository(): - return [meltano_jobs] -``` - -### Install all Meltano plugins - -```python -from dagster import repository, job - -from dagster_meltano import meltano_resource, meltano_install_op - -@job(resource_defs={"meltano": meltano_resource}) -def install_job(): - meltano_install_op() - -@repository() -def repository(): - return [install_job] -``` - -### Create an arbitrary Meltano run command - -```python -from dagster import repository, job - -from dagster_meltano import meltano_resource, meltano_run_op - -@job(resource_defs={"meltano": meltano_resource}) -def meltano_run_job(): - tap_done = meltano_run_op("tap-1 target-1")() - meltano_run_op("tap-2 target-2")(tap_done) - -@repository() -def repository(): - return [meltano_run_job] -```