ONTONYM Memories Pricing DocsSign in Register

feedgraphagentsbrowseschedulesremindersquestionscalendar

Loading memory…

Memories/Apache Airflow/person

1fanwang

https://github.com/1fanwang

authored → pull request54

[DEMO ONLY] AIP-96: resumable operator example for discussion
Add durable option to TriggerDagRunOperator to reconnect on retry
Add on_task_instance_checkpointed listener hook
Add opt-in concurrent pod creation to KubernetesExecutor
Add required context messages to all DagRun state change notifications
Add required context messages to all DagRun state change notifications (#56272)
Add required context messages to all task instance state change notifications
AIP-96 (draft): add CHECKPOINTED state and AirflowTaskCheckpointed exception
AIP-96: wire CHECKPOINTED through supervisor → API server → DB
AIP-97 (draft): add FailureDetails primitive for infrastructure-side failure con
airflowctl: make required CLI params positional, keep optional as --flag
airflowctl: make required CLI params positional, keep optional as --flag (#66768
Avoid long row locks in sensor reschedule path under high concurrency
Distinguish upstream_failed from failed in normal vision (#66324)
Don't silently mark TI FAILED when state-update payload exceeds column type
Don't surface duplicate-key Dag-write race between Dag processors as import erro
Emit dagrun.first_task_start_delay separate from scheduling_delay
Emit dagrun.first_task_start_delay separate from scheduling_delay (#66807)
Emit OpenTelemetry spans from airflow CLI entry points
Extend listener hook-name log to remaining call sites
Factor out a shared base for the database error handlers
Factor out a shared base for the database error handlers (#68512)
feat(metrics): emit dagrun.deadlocked counter on task-deadlock detection
feat(metrics): emit pool slot histograms alongside existing gauges

See all 54 in Browse →

contributes to → repository26

Apache Airflow
apache/auron
apache/hive
atlassian-api/atlassian-python-api
ClickHouse/clickhouse-operator
cocoindex-io/cocoindex
dagster-io/dagster
delta-io/delta-rs
facebookincubator/velox
feast-dev/feast
flyteorg/flyte
flyteorg/flyteconsole

contributor profile → profiles1

1fanwang (OSS)

Explore Apache Airflow in Browse →

flyteorg/flytekit

kubeflow/trainer

openclaw/openclaw

PrefectHQ/prefect

pytorch/pytorch

ray-project/kuberay

sgl-project/sglang

tikv/raft-engine

valkey-io/valkey

See all 26 in Browse →

1fanwang — Apache Airflow