Skip to main content

convalesce-emit-airflow

Forward Airflow run events to Convalesce, unchanged.

Install

pip install convalesce-emit-airflow

That is the whole integration. The package registers a listener through Airflow's airflow.plugins entry point, so nothing in a DAG changes. Set CONVALESCE_INGEST_KEY on the worker and every task instance and dag run event is forwarded as it happens.

Supported

Airflow 2.5 through 3.0 in this one release, on Python 3.9 and later. The listener generates its hooks from the hookspecs of the Airflow it runs in, so a release that adds or removes a hook argument cannot break it. Airflow passes a task's failure message to listeners from 2.10.

Verified on real installs: see version-support.md.

Configure

CONVALESCE_INGEST_KEY, CONVALESCE_ENDPOINT, CONVALESCE_DRY_RUN and the rest are read from the environment: see convalesce-emit.

Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

convalesce_emit_airflow-0.1.1.tar.gz (12.5 kB view details)

Uploaded Source

Built Distribution

If you're not sure about the file name format, learn more about wheel file names.

convalesce_emit_airflow-0.1.1-py3-none-any.whl (11.8 kB view details)

Uploaded Python 3

File details

Details for the file convalesce_emit_airflow-0.1.1.tar.gz.

File metadata

  • Download URL: convalesce_emit_airflow-0.1.1.tar.gz
  • Upload date:
  • Size: 12.5 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? Yes
  • Uploaded via: twine/7.0.0 CPython/3.13.14

File hashes

Hashes for convalesce_emit_airflow-0.1.1.tar.gz
Algorithm Hash digest
SHA256 1676df85cad690fc10ac70ffbf415be7a0d75043ee8f3d03812ec534d304c368
MD5 3f64eaf4de4d746a39265d510118cf78
BLAKE2b-256 4aacff267cebdb4b4643332a14daf9b1a06be0761ecd403dbda743da8d07ed27

See more details on using hashes here.

Provenance

The following attestation bundles were made for convalesce_emit_airflow-0.1.1.tar.gz:

Publisher: publish.yml on convalesce/emit

Attestations: Values shown here reflect the state when the release was signed and may no longer be current.

File details

Details for the file convalesce_emit_airflow-0.1.1-py3-none-any.whl.

File metadata

File hashes

Hashes for convalesce_emit_airflow-0.1.1-py3-none-any.whl
Algorithm Hash digest
SHA256 168c1a5db310711d4d52c1f9983fe831d85454517e3c6390bad719f3ab9eb684
MD5 97d4fa7832cbb246c18e1691453c8e79
BLAKE2b-256 e5a77a74ae0c9d357eff79f6feacb29820b3c1eb388f4baab8f56b0e864dc26d

See more details on using hashes here.

Provenance

The following attestation bundles were made for convalesce_emit_airflow-0.1.1-py3-none-any.whl:

Publisher: publish.yml on convalesce/emit

Attestations: Values shown here reflect the state when the release was signed and may no longer be current.

Release history Release notifications | RSS feed

This release

0.1.1 This release

2 files

0.1.0

2 files

Anthropic, PBC Visionary sponsor Bloomberg Visionary sponsor Hudson River Trading Visionary sponsor Meta Visionary sponsor NVIDIA Visionary sponsor Microsoft Sustainability sponsor Depot Continuous Integration AWS Cloud computing and Security Sponsor Datadog Monitoring Fastly CDN Google Download Analytics Sentry Error logging StatusPage Status page