Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
10 changes: 7 additions & 3 deletions go-sdk/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@ Longer term we will likely need to stabilize the Edge Executor API and add versi

Since Go is a compiled language (putting aside projects such as [YAEGI](https://github.com/traefik/yaegi) that allow Go to be interpreted), all tasks must:

1. Be compiled into a binary ahead of time, and
1. Be compiled into a binary ahead of time, and
2. Be registered inside the worker process in order to be executed.


Expand All @@ -49,7 +49,7 @@ Since Go is a compiled language (putting aside projects such as [YAEGI](https://

- Configure the go edge worker, by editing `$AIRFLOW_HOME/go-sdk.yaml`:

These config values need tweaking, expecially the ports and secrets. The ports are the default assuming
These config values need tweaking, especially the ports and secrets. The ports are the default assuming
airflow is running locally via `airflow standalone`.

```toml
Expand Down Expand Up @@ -95,17 +95,21 @@ You will need to create a python Dag and deploy it in to the Airflow
```python
from airflow.sdk import dag, task


@task.stub(queue="golang")
def extract():...
def extract(): ...


@task.stub(queue="golang")
def transform(): ...


@dag()
def simple_dag():

extract() >> transform()


multi_language()
```

Expand Down