Senior Data Engineer
benchflow-ai/skillsbench
World-class data engineering skill for building scalable data pipelines, ETL/ELT systems, real-time streaming, and data infrastructure.
Writes Airflow task logic in Go using the Airflow Go SDK. An agent skill from astronomer/agents.
$ npx skills add astronomer/agents --skill authoring-go-sdk-tasks -a claude-codeProject install by default; add -g for ~/.claude/skills/.
$ gh skill install astronomer/agents authoring-go-sdk-tasks --agent claude-codeProject scope by default; add --scope user for a personal install. Needs GitHub CLI 2.90.0 or later (public preview).
$ git clone --depth 1 https://github.com/astronomer/agents.git skills-src && mkdir -p .claude/skills && cp -r skills-src/skills/authoring-go-sdk-tasks .claude/skills/authoring-go-sdk-tasks && rm -rf skills-srcUse ~/.claude/skills/ instead of .claude/skills for a personal install. The folder must contain SKILL.md.
Claude Code skills documentation · loads skills from .claude/skills/
Install the "authoring-go-sdk-tasks" agent skill from https://github.com/astronomer/agents/tree/main/skills/authoring-go-sdk-tasks into .claude/skills/authoring-go-sdk-tasks/ in this project. Copy the whole folder (SKILL.md and every file beside it), keep the folder name "authoring-go-sdk-tasks", then confirm the skill loads.Claude Code copies the folder itself, the same result as the manual copy. Check what it changed before you commit it.
$skill-installer install https://github.com/astronomer/agents/tree/main/skills/authoring-go-sdk-tasksType this inside Codex. $skill-installer <name> installs a curated skill from openai/skills. The installer writes to $CODEX_HOME/skills (default ~/.codex/skills). Restart Codex if the skill does not show up.
$ npx skills add astronomer/agents --skill authoring-go-sdk-tasks -a codexProject install goes to .agents/skills/; add -g for ~/.codex/skills/.
$ gh skill install astronomer/agents authoring-go-sdk-tasks --agent codexProject scope by default (.agents/skills/); add --scope user for a personal install.
$ git clone --depth 1 https://github.com/astronomer/agents.git skills-src && mkdir -p .agents/skills && cp -r skills-src/skills/authoring-go-sdk-tasks .agents/skills/authoring-go-sdk-tasks && rm -rf skills-srcUse ~/.agents/skills/ instead of .agents/skills for a personal install.
Codex skills documentation · loads skills from .agents/skills/
Install the "authoring-go-sdk-tasks" agent skill from https://github.com/astronomer/agents/tree/main/skills/authoring-go-sdk-tasks into .agents/skills/authoring-go-sdk-tasks/ in this project. Copy the whole folder (SKILL.md and every file beside it), keep the folder name "authoring-go-sdk-tasks", then confirm the skill loads.Codex copies the folder itself, the same result as the manual copy. Check what it changed before you commit it.
$ npx skills add astronomer/agents --skill authoring-go-sdk-tasks -a cursorProject install goes to .agents/skills/; add -g for ~/.cursor/skills/.
$ gh skill install astronomer/agents authoring-go-sdk-tasks --agent cursorProject scope by default (.agents/skills/); add --scope user for a personal install.
$ git clone --depth 1 https://github.com/astronomer/agents.git skills-src && mkdir -p .cursor/skills && cp -r skills-src/skills/authoring-go-sdk-tasks .cursor/skills/authoring-go-sdk-tasks && rm -rf skills-srcUse ~/.cursor/skills/ instead of .cursor/skills for a personal install.
Cursor skills documentation · loads skills from .cursor/skills/, .agents/skills/, .claude/skills/, .codex/skills/
Install the "authoring-go-sdk-tasks" agent skill from https://github.com/astronomer/agents/tree/main/skills/authoring-go-sdk-tasks into .cursor/skills/authoring-go-sdk-tasks/ in this project. Copy the whole folder (SKILL.md and every file beside it), keep the folder name "authoring-go-sdk-tasks", then confirm the skill loads.Cursor copies the folder itself, the same result as the manual copy. Check what it changed before you commit it.
$ gemini skills install https://github.com/astronomer/agents.git --path skills/authoring-go-sdk-tasks--scope user (default) or --scope workspace; --path is the subfolder of the repo that holds the skill; --consent skips the security confirmation prompt.
$ npx skills add astronomer/agents --skill authoring-go-sdk-tasks -a gemini-cliProject install goes to .agents/skills/; add -g for ~/.gemini/skills/.
$ gh skill install astronomer/agents authoring-go-sdk-tasks --agent gemini-cliProject scope by default (.agents/skills/); add --scope user for a personal install.
$ git clone --depth 1 https://github.com/astronomer/agents.git skills-src && mkdir -p .gemini/skills && cp -r skills-src/skills/authoring-go-sdk-tasks .gemini/skills/authoring-go-sdk-tasks && rm -rf skills-srcUse ~/.gemini/skills/ instead of .gemini/skills for a personal install, then run /skills reload.
Gemini CLI skills documentation · loads skills from .gemini/skills/, .agents/skills/
Install the "authoring-go-sdk-tasks" agent skill from https://github.com/astronomer/agents/tree/main/skills/authoring-go-sdk-tasks into .gemini/skills/authoring-go-sdk-tasks/ in this project. Copy the whole folder (SKILL.md and every file beside it), keep the folder name "authoring-go-sdk-tasks", then confirm the skill loads.Gemini CLI copies the folder itself, the same result as the manual copy. Check what it changed before you commit it.
$ gh skill install astronomer/agents authoring-go-sdk-tasksInstalls for Copilot at project scope by default; add --scope user for a personal install. Preview a skill first with gh skill preview. Needs GitHub CLI 2.90.0 or later (public preview).
$ npx skills add astronomer/agents --skill authoring-go-sdk-tasks -a github-copilotProject install goes to .agents/skills/; add -g for ~/.copilot/skills/.
$ git clone --depth 1 https://github.com/astronomer/agents.git skills-src && mkdir -p .github/skills && cp -r skills-src/skills/authoring-go-sdk-tasks .github/skills/authoring-go-sdk-tasks && rm -rf skills-srcUse ~/.copilot/skills/ instead of .github/skills for a personal install. Commit .github/skills so cloud agent and code review can use it.
GitHub Copilot skills documentation · loads skills from .github/skills/, .claude/skills/, .agents/skills/
Install the "authoring-go-sdk-tasks" agent skill from https://github.com/astronomer/agents/tree/main/skills/authoring-go-sdk-tasks into .github/skills/authoring-go-sdk-tasks/ in this project. Copy the whole folder (SKILL.md and every file beside it), keep the folder name "authoring-go-sdk-tasks", then confirm the skill loads.GitHub Copilot copies the folder itself, the same result as the manual copy. Check what it changed before you commit it.
$ npx skills add astronomer/agents --skill authoring-go-sdk-tasks -a opencodeOpenCode documents no install command of its own. Project install goes to .agents/skills/; add -g for ~/.config/opencode/skills/.
$ gh skill install astronomer/agents authoring-go-sdk-tasks --agent opencodeProject scope by default (.agents/skills/); add --scope user for a personal install.
$ git clone --depth 1 https://github.com/astronomer/agents.git skills-src && mkdir -p .opencode/skills && cp -r skills-src/skills/authoring-go-sdk-tasks .opencode/skills/authoring-go-sdk-tasks && rm -rf skills-srcUse ~/.config/opencode/skills/ instead of .opencode/skills for a personal install.
OpenCode skills documentation · loads skills from .opencode/skills/, .claude/skills/, .agents/skills/
Install the "authoring-go-sdk-tasks" agent skill from https://github.com/astronomer/agents/tree/main/skills/authoring-go-sdk-tasks into .opencode/skills/authoring-go-sdk-tasks/ in this project. Copy the whole folder (SKILL.md and every file beside it), keep the folder name "authoring-go-sdk-tasks", then confirm the skill loads.OpenCode copies the folder itself, the same result as the manual copy. Check what it changed before you commit it.
authoring-go-sdk-tasksWrites Airflow task logic in Go using the Airflow Go SDK. An agent skill from astronomer/agents.
Authoring Go SDK Tasks is an agent skill from astronomer/agents. Writes Airflow task logic in Go using the Airflow Go SDK. Use when the user wants to implement Airflow tasks in Go, asks about BundleProvider/RegisterDags, the bundlev1 Registry/Dag interfaces, registering Go tasks (AddTask/AddTaskWithName), dependency injection by parameter type (context.Context, sdk.TIRunContext, slog.Logger, sdk.Client), or reading connections/variables/XComs from Go. This skill covers the Go-specific native API; the shared Python-stub pattern and conceptual model live in…
Its SKILL.md is about 2.1k tokens, which your agent loads only when the skill is triggered. It is a single SKILL.md file with no bundled scripts.
It sits in Data & Analytics, covering Data pipelines and ETL and Design patterns. It works with Apache Airflow and Python. The repository describes itself as: AI agent tooling for data engineering workflows. The licence is Apache-2.0.
Read from SKILL.md and the folder at commit 486ee63. It shows what the files ask for, not the result of running them.
Pre-approves nothing: there is no allowed-tools line, so your agent's usual permission prompts apply.
From allowed-tools in the SKILL.md frontmatter.
Shell commands in SKILL.md call:
goFrom the folder's file list and the shell code blocks in SKILL.md.
No URLs in SKILL.md.
From URLs in SKILL.md, links to its own repository left out.
Names no API keys, tokens, secrets or passwords.
From names ending in _API_KEY, _TOKEN, _SECRET, _KEY or _PASSWORD in SKILL.md.
Authoring Go SDK Tasks loads about 2.1k tokens when it runs. Until then it costs about 175 tokens; SKILL.md has 760 words of instructions outside code blocks.
Estimates: characters ÷ 4, the usual rule of thumb; real counts depend on the model's tokenizer. Scripts and assets cost tokens only if the agent reads them.
The automated check found no risky patterns in SKILL.md.
Automated static check — not a guarantee. Review scripts before installing. It scans the text of SKILL.md for risky patterns (piping downloads into a shell, reading credential files, hidden Unicode, destructive commands); files beside SKILL.md are not scanned.
The full file from astronomer/agents at commit 486ee63, republished under its Apache-2.0 licence (© astronomer). 760 words, ~2,137 tokens.
.claude/skills/authoring-go-sdk-tasks/SKILL.md (or your agent's skills folder).The Airflow Go SDK implements the language-SDK model for Go: your DAG stays in Python, and each task is a compiled Go function registered inside a bundle (a single native executable). This skill covers the Go-specific native API. The shared model (the Python @task.stub pattern, ID matching, the XCom-as-JSON contract) lives in authoring-language-sdk-tasks; read that first if you are new to language SDKs.
Experimental. The Go SDK is under active development and not production-ready. Module path
github.com/apache/airflow/go-sdk(Go 1.24+). APIs may change.
Related skills: authoring-language-sdk-tasks (shared Python stub + concepts), deploying-go-sdk-bundles (build, pack, and ship the bundle), configuring-airflow-language-sdks (route the queue to the Go coordinator).
A Go task is paired with a Python stub that carries no logic; it declares the task, its queue, and the dependency graph. IDs must match the Go registration exactly, and queue= routes the task to the Go runtime. Full rules are in authoring-language-sdk-tasks; the minimal shape:
from airflow.sdk import dag, task
@task.stub(queue="golang")
def extract(): ...
@task.stub(queue="golang")
def transform(): ...
@dag()
def simple_dag():
extract() >> transform()
simple_dag()The queue value ("golang" here) is an arbitrary label that must match the queue routed to the Go coordinator (queue_to_coordinator). See configuring-airflow-language-sdks.
A bundle implements bundlev1.BundleProvider: report its version and register your DAGs and tasks. main is one line; bundlev1server.Serve wires the bundle to the Airflow runtime for you.
package main
import (
"log"
v1 "github.com/apache/airflow/go-sdk/bundle/bundlev1"
"github.com/apache/airflow/go-sdk/bundle/bundlev1/bundlev1server"
)
type myBundle struct{}
var _ v1.BundleProvider = (*myBundle)(nil)
func (m *myBundle) GetBundleVersion() v1.BundleInfo {
return v1.BundleInfo{Name: bundleName, Version: &bundleVersion}
}
func (m *myBundle) RegisterDags(dagbag v1.Registry) error {
simpleDag := dagbag.AddDag("simple_dag") // dag_id must match the Python @dag name
simpleDag.AddTask(extract) // task_id is the function name; must match the stub
simpleDag.AddTaskWithName("transform", transform) // or set the task_id explicitly
return nil
}
func main() {
if err := bundlev1server.Serve(&myBundle{}); err != nil {
log.Fatal(err)
}
}AddTask(fn) derives the task_id from the Go function's name; use AddTaskWithName("<task_id>", fn) when that name can't match the Python stub (an unexported, renamed, or reused function). RegisterDags is the single source of truth for task identity: the bundle's manifest (used by the packer and by the coordinator) is generated by running it, never hand-written.
A task is an ordinary Go function. The runtime inspects its signature and injects arguments by type; declare only what you need.
| Parameter type | Injected value |
|---|---|
context.Context | Task context for cancellation. Always available. |
sdk.TIRunContext | Richer context (embeds context.Context) exposing TaskInstance() and DagRun(). See Runtime context. |
*slog.Logger | Logger wired to the Airflow task log. |
sdk.Client | Full Airflow model access: Variables, Connections, XComs. |
sdk.VariableClient / sdk.ConnectionClient / sdk.XComClient | A narrower slice of sdk.Client. Prefer the narrowest you need; it documents intent and is trivial to fake in tests. |
The optional return signature is (result, error): a non-nil result is pushed as the task's return_value XCom; a non-nil error fails the task (which triggers the stub's retry policy). Returning only error, or nothing, is also valid.
func extract(ctx sdk.TIRunContext, client sdk.Client, log *slog.Logger) (any, error) {
conn, err := client.GetConnection(ctx, "test_http")
if err != nil {
return nil, err
}
log.Info("connected", "host", conn.Host)
return map[string]any{"go_version": runtime.Version()}, nil
}
func transform(ctx sdk.TIRunContext, client sdk.VariableClient) error {
val, err := client.GetVariable(ctx, "my_variable")
if err != nil {
return err // VariableNotFound (a sentinel error) if absent
}
_ = val
return nil
}sdk.Client surface| Call | Returns | Notes |
|---|---|---|
GetVariable(ctx, key) | (string, error) | VariableNotFound if absent. |
UnmarshalJSONVariable(ctx, key, &ptr) | error | Decode a JSON variable into a struct/pointer. |
GetConnection(ctx, connID) | (Connection, error) | ConnectionNotFound if absent. |
GetXCom(ctx, dagID, runID, taskID, mapIndex, key, value) | (any, error) | XComNotFound only if the key is absent; a stored null returns (nil, nil). |
PushXCom(ctx, ti, key, value) | error | Rarely needed; a returned value is pushed for you. |
Connection exposes ID, Type, Host, Port (int), Login *string, Password *string (nil when unset, distinct from empty), Path (schema), Extra map[string]any, plus GetURI(). Not-found cases return the sentinels sdk.VariableNotFound, sdk.ConnectionNotFound, sdk.XComNotFound.
To read an upstream task's result, call GetXCom explicitly, taking the dag_id/run_id/task_id you need from the runtime context (below).
Declare an sdk.TIRunContext parameter to read metadata about the task instance and its DAG run. It is an interface that embeds context.Context, so it is usable anywhere a context.Context is expected.
func extract(ctx sdk.TIRunContext, log *slog.Logger) error {
ti, dagRun := ctx.TaskInstance(), ctx.DagRun()
log.Info("running",
"task_id", ti.TaskID,
"run_id", dagRun.RunID,
"logical_date", dagRun.LogicalDate)
return nil
}TaskInstance(): DagID, RunID, TaskID, MapIndex *int (nil when unmapped), TryNumber.DagRun(): DagID, RunID, and the *time.Time timestamps LogicalDate, DataIntervalStart, DataIntervalEnd (nil when not sent).The accessors are populated from the task's startup details before the body runs. Because TIRunContext embeds context.Context, pass it straight to client calls and cancellation checks (ctx.Done()); declare it as your context parameter by default. In tests, build the argument with sdk.NewTIRunContext(ctx, ti, dagRun) (it panics on a nil ctx).
dag_id from AddDag, task_id from the registered function name), and the stub's queue= must route to the Go coordinator, or the task is never delivered.RegisterDags is authoritative. Do not hand-write the manifest; the packer generates it by running RegisterDags.sdk.VariableClient over sdk.Client) for clearer intent and easier fakes.error return fails the task and applies the stub's retries; a recovered panic is also a failure.go tool airflow-go-pack, then deploy it for the coordinator.ExecutableCoordinator).© astronomer, Apache-2.0. Rendered from Markdown: HTML in the file is shown as text, images as links, and headings moved down two levels. Raw file
Just SKILL.md in skills/authoring-go-sdk-tasks of astronomer/agents.
Open the folder on GitHubat commit 486ee63
Authoring Go SDK Tasks next to the 5 skills that share the most tags, products or categories with it. Stars are the repository's; “used in” counts other GitHub owners with a copy.
| Skill | Stars | Used in | Tokens | Auto-check | Licence | Repo updated |
|---|---|---|---|---|---|---|
| Authoring Go SDK Tasks this skillastronomer/agents | 451 | — | ~2.1k | Automated safety check: Pass | Apache-2.0 | |
| Senior Data Engineerbenchflow-ai/skillsbench | 1.8k | — | ~5.9k | Automated safety check: Pass | MIT | |
| Airflow DAG Patternswshobson/agents | 40k | 9 repos | ~784 | Automated safety check: Pass | MIT | |
| Version Bumpergodatadriven/whirl | 205 | — | ~1.2k | Automated safety check: Pass | Apache-2.0 | |
| Senior Data Engineeralirezarezvani/claude-skills | 28k | 3 repos | ~1.4k | Automated safety check: Pass | MIT | |
| Senior Data Engineerdavila7/claude-code-templates | 33k | 1 repos | ~1.4k | Automated safety check: Pass | MIT |
benchflow-ai/skillsbench
World-class data engineering skill for building scalable data pipelines, ETL/ELT systems, real-time streaming, and data infrastructure.
wshobson/agents
Patterns for writing production-ready Apache Airflow DAGs: task dependencies, custom operators and sensors, local testing, and rules for what to avoid.
godatadriven/whirl
Bump the Airflow or Python version across all project files.
alirezarezvani/claude-skills
Data engineering skill for building scalable data pipelines, ETL/ELT systems, and data infrastructure.
davila7/claude-code-templates
World-class data engineering skill for building scalable data pipelines, ETL/ELT systems, and data infrastructure.
ancoleman/ai-design-components
Transform raw data into analytical assets using ETL/ELT patterns, SQL (dbt), Python (pandas/polars/PySpark), and orchestration (Airflow).
astronomer/agents
Queries the data warehouse with SQL and answers business questions about data.
astronomer/agents
Queries, manages, and troubleshoots Apache Airflow using the af CLI.
astronomer/agents
Guide for migrating Dagster projects to Apache Airflow 3 on Astro.
astronomer/agents
Workflow and best practices for writing Apache Airflow DAGs.
astronomer/agents
Deploys Airflow DAGs and projects. An agent skill from astronomer/agents.
astronomer/agents
Builds human-in-the-loop (HITL) Airflow workflows - approval gates, form input, and human-driven branching.
Works with
Categories
Writes Airflow task logic in Go using the Airflow Go SDK. An agent skill from astronomer/agents. Authoring Go SDK Tasks is an agent skill from astronomer/agents. Writes Airflow task logic in Go using the Airflow Go SDK.
Authoring Go SDK Tasks fits situations like: the user wants to implement Airflow tasks in Go; asks about BundleProvider/RegisterDags; the bundlev1 Registry/Dag interfaces; registering Go tasks (AddTask/AddTaskWithName).
Run `npx skills add astronomer/agents --skill authoring-go-sdk-tasks -a claude-code`. Or copy the skill folder (skills/authoring-go-sdk-tasks in astronomer/agents) into .claude/skills/authoring-go-sdk-tasks in your project. Claude Code loads it when a task matches its description.
Run `npx skills add astronomer/agents --skill authoring-go-sdk-tasks -a codex`. Or copy the skill folder (skills/authoring-go-sdk-tasks in astronomer/agents) into .agents/skills/authoring-go-sdk-tasks in your project. Codex loads it when a task matches its description.
Cursor, Gemini CLI, GitHub Copilot and OpenCode also load SKILL.md folders. With the skills CLI, run `npx skills add astronomer/agents --skill authoring-go-sdk-tasks -a cursor` (or -a gemini-cli, github-copilot or opencode for the others). To copy it by hand, put the folder in .cursor/skills/authoring-go-sdk-tasks, .gemini/skills/authoring-go-sdk-tasks, .github/skills/authoring-go-sdk-tasks and .opencode/skills/authoring-go-sdk-tasks in your project.
Going by SKILL.md and its folder, Authoring Go SDK Tasks needs the command-line tools its instructions call (go). Our summary lists: Python 3.
SKILL.md contains no URLs. Any network use would come from the scripts or tools the agent runs. This is read from the text; nothing was executed.
Our automated static check of SKILL.md found no risky patterns, such as piping downloads into a shell, reading credential files or hidden Unicode. It is not a guarantee. Review the folder before installing.
Authoring Go SDK Tasks is published under the Apache-2.0 licence (the repository's licence). It allows redistribution, so the full SKILL.md is shown on this page.
About 2.1k tokens (SKILL.md is roughly 8.5k characters). Agents keep only the skill's name and description in context until a task matches; then they load SKILL.md in full.
Skills that share tags, products or a category with Authoring Go SDK Tasks: Senior Data Engineer (benchflow-ai/skillsbench, 1.8k stars), Airflow DAG Patterns (wshobson/agents, 40k stars), Version Bumper (godatadriven/whirl, 205 stars) and Senior Data Engineer (alirezarezvani/claude-skills, 28k stars). The comparison table on this page puts their stars, adoption, token cost, safety result and licence side by side.
astronomer (a GitHub organization) maintains it in astronomer/agents, which has 451 GitHub stars. The repository holds 34 skills in this directory. The repository was last updated on October 7, 2026.
Source: astronomer/agents on GitHub. Facts on this page come from the repository at the commit we read; the author's words are quoted as theirs.