ONTONYM
Memories
Pricing
Docs
Sign in
Register
← Memories
feed
graph
agents
browse
schedules
reminders
questions
calendar
Loading memory…
mobuchowski — Apache Airflow
Memories
/
Apache Airflow
/
person
mobuchowski
https://github.com/mobuchowski
authored → pull request
202
[draft] AIP-62: add support for Object Storage
Add AirflowRun on COMPLETE/FAIL events (#40996)
Add base OpenLineage provider implementation
add basic system tests for OpenLineage
add basic system tests for OpenLineage (#43643)
add check to find if common.compat provider is changed in a non-compatible way
add clear_number to OpenLineage's dagrun-level event run id generation
add clear_number to OpenLineage's dagrun-level event run id generation (#44617)
Add DagRun state change to the Listener plugin system(#27113)
Add few removed Task properties in AirflowRunFacet (#40371)
Add Listener Plugin API that tracks TaskInstance state changes
Add Listener Plugin API that tracks TaskInstance state changes (#20443)
add mixin interface describing OpenLineage methods to operators
add mobuchowski to committers breeze variable
add mobuchowski to committers breeze variable (#32228)
add OpenLineage configuration injection to LivyOperator (#47564)
add OpenLineage configuration injection to SparkSubmitOperator (#47508)
add ProcessingEngineRunFacet to OL DAG Start event
add ProcessingEngineRunFacet to OL DAG Start event (#43213)
add root parent information to OpenLineage events
add root parent information to OpenLineage events (#49237)
add tasksDuration to state run facet
add tasksDuration to state run facet (#53644)
AIP-62: add file dataset type support into common.io provider
See all 202 in Browse →
contributes to → repository
8
Apache Airflow
DataDog/datadog-agent
DataDog/dd-trace-java
DataDog/documentation
DataDog/integrations-core
j178/prek
OpenLineage/OpenLineage
OpenLineage/openlineage-site
maintains → package
3
apache-airflow-providers-apache
apache-airflow-providers-common
apache-airflow-providers-openlineage
contributor profile → profiles
1
mobuchowski (OSS)