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.0.tar.gz (10.2 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.0-py3-none-any.whl (10.7 kB view details)

Uploaded Python 3

File details

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

File metadata

  • Download URL: convalesce_emit_airflow-0.1.0.tar.gz
  • Upload date:
  • Size: 10.2 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.0.tar.gz
Algorithm Hash digest
SHA256 230b122d5399575b9d744b1077a1ded9b924e499a4e05e77323a0e84f83a0781
MD5 3613862b7ad3f049b9b4d4f56c2def1e
BLAKE2b-256 58103a1e7bb37489f5f9f20c01a780970461b1f08b1199dcabda2e1a328a6bc1

See more details on using hashes here.

Provenance

The following attestation bundles were made for convalesce_emit_airflow-0.1.0.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.0-py3-none-any.whl.

File metadata

File hashes

Hashes for convalesce_emit_airflow-0.1.0-py3-none-any.whl
Algorithm Hash digest
SHA256 33d9f0a4c06d92a555a01adbfb881dd162b67717608f9a2351df34fd31347d66
MD5 b522b5c831b8ac7d92b9947658968d70
BLAKE2b-256 7b2cf5a7f3985e0b4094f80c44908cebfd1ac29435d047417c0dd593d8774c7c

See more details on using hashes here.

Provenance

The following attestation bundles were made for convalesce_emit_airflow-0.1.0-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

0.1.1

2 files

This release

0.1.0 This release

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