Skip to content

Commit

Permalink
Added to readme
Browse files Browse the repository at this point in the history
  • Loading branch information
JulesHuisman committed Dec 30, 2022
1 parent c739950 commit 2d5065c
Showing 1 changed file with 1 addition and 52 deletions.
53 changes: 1 addition & 52 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -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

Expand Down Expand Up @@ -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("<path-to-meltano-root>")

@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]
```

0 comments on commit 2d5065c

Please sign in to comment.