diff --git a/go-sdk/README.md b/go-sdk/README.md index 179f0ba8c99e2..b873cd0211430 100644 --- a/go-sdk/README.md +++ b/go-sdk/README.md @@ -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. @@ -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 @@ -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() ```