Skip to main content

Machine Learning Orchestration

Project description

Dbnd Airflow Operator

This plugin was written to provide an explicit way of declaratively passing messages between two airflow operators.

This plugin was inspired by AIP-31. Essentially, this plugin connects between dbnd's implementation of tasks and pipelines to airflow operators.

This implementation uses XCom communication and XCom templates to transfer said messages. This plugin is fully functional, however as soon as AIP-31 is implemented it will support all edge-cases.

Fully tested on airflow 1.10.X.

Project details


Release history Release notifications | RSS feed

Download files

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

Source Distribution

dbnd-airflow-operator-0.25.5.tar.gz (12.6 kB view details)

Uploaded Source

Built Distribution

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

dbnd_airflow_operator-0.25.5-py2.py3-none-any.whl (13.3 kB view details)

Uploaded Python 2Python 3

File details

Details for the file dbnd-airflow-operator-0.25.5.tar.gz.

File metadata

  • Download URL: dbnd-airflow-operator-0.25.5.tar.gz
  • Upload date:
  • Size: 12.6 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/3.1.1 pkginfo/1.5.0.1 requests/2.22.0 setuptools/42.0.2 requests-toolbelt/0.9.1 tqdm/4.42.0 CPython/3.6.3

File hashes

Hashes for dbnd-airflow-operator-0.25.5.tar.gz
Algorithm Hash digest
SHA256 843659f56ac5cc12b7505111d444fb6af4a20145ca9689f7a8a62445b3f078e1
MD5 bc9482f88d360d2b0cabf7b757c3901b
BLAKE2b-256 ede5073946e5331eb60f4c76841a891c366a057e91c79a39b2f23c837b0ba86c

See more details on using hashes here.

File details

Details for the file dbnd_airflow_operator-0.25.5-py2.py3-none-any.whl.

File metadata

  • Download URL: dbnd_airflow_operator-0.25.5-py2.py3-none-any.whl
  • Upload date:
  • Size: 13.3 kB
  • Tags: Python 2, Python 3
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/3.1.1 pkginfo/1.5.0.1 requests/2.22.0 setuptools/42.0.2 requests-toolbelt/0.9.1 tqdm/4.42.0 CPython/3.6.3

File hashes

Hashes for dbnd_airflow_operator-0.25.5-py2.py3-none-any.whl
Algorithm Hash digest
SHA256 6c96c9f0390c8163e23fa2bb4d3a8787899e69462fd325392a91932d9427bc77
MD5 97e41cc5d1808cc2367fdb1c0cb84f7b
BLAKE2b-256 1d241ceec13c3e16f5d38f8ee32edee8ac158951eba1a7b5061ea9660410ea68

See more details on using hashes here.

Supported by

AWS Cloud computing and Security Sponsor Datadog Monitoring Depot Continuous Integration Fastly CDN Google Download Analytics Pingdom Monitoring Sentry Error logging StatusPage Status page