
Annotating Task Lineage
作者 astronomercbe1141f547b无许可证451 个星标收录于 2026年10月8日更新于 2026年10月8日仓库今天更新
Annotate Airflow tasks with data lineage using inlets and outlets. Use when the user wants to add lineage metadata to tasks, specify input/output datasets, or enable lineage tracking for operators without built-in OpenLineage extraction.
- cbe1141f547b当前提交 cbe1141发布于 2026年10月8日
来源与署名
来源:astronomer/agents位于skills/annotating-task-lineage提交cbe1141
许可证: 无许可证
内容归原作者所有。SourceWeft 从公开仓库中收录这些内容。
更多来自 astronomer/agents 的技能

Warehouse Init
astronomer
发现数据仓库的模式元数据,并生成可共享的 .astro/warehouse.md 参考文件,以便快速进行概念到表的查找。

Tracing Upstream Lineage
astronomer
Trace upstream data lineage. Use when the user asks where data comes from, what feeds a table, upstream dependencies, data sources, or needs to understand data origins.

Tracing Downstream Lineage
astronomer
追踪下游数据血缘,评估表或 DAG 变更会造成哪些影响。

Testing Dags
astronomer
指导使用 af 命令行工具对 Airflow DAG 进行迭代式测试、调试与修复。

Setting Up Astro Project
astronomer
使用 Astro CLI 初始化并配置 Astro/Airflow 项目,涵盖依赖、连接与变量。

Profiling Tables
astronomer
通过 SQL 统计、基数分析、样本数据和数据质量评估,对数据库表进行剖析。
更多Data & Analytics技能

Creating Openlineage Extractors
astronomer
指导为缺少内置血缘支持的 Airflow 算子创建自定义 OpenLineage 提取器。

Checking Freshness
astronomer
通过查询时间戳列检查数据库表的数据新鲜度,并报告过期状态。

Blueprint
astronomer
指导构建带 Pydantic 校验的可复用 Airflow DAG 模板,并用 YAML 组合 DAG。

Weekly Brief
amplitude
生成 Amplitude 每周分析简报,涵盖趋势、成果、风险及下周优先事项。

User Cohort Forensics
amplitude
在 Amplitude 中调查单个用户与用户群体,解析身份、读取资料并分析事件时间线。

Taxonomy
amplitude
Amplitude 事件分类体系参考指南:命名规范、数据质量审计、评分与安全弃用流程。