Apache Airflow integration for Kaldea
Project description
airflow-kaldea
This is a collection of Airflow operators to provide integration with Kaldea.
from airflow.models import DAG
from airflow_kaldea.operators.kaldea_job_operator import KaldeaJobOperator
default_args = {}
dag = DAG(
dag_id='data_dag',
default_args=default_args,
schedule_interval='0 * * * *',
)
kaldea_job = KaldeaJobOperator(
task_id='kaldea_job',
kaldea_job_id='kaldea_job_id',
kaldea_task_id='kaldea_task_id',
dag=dag,
)
Installation
Install from PyPI:
pip install airflow-kaldea
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
airflow_kaldea-0.0.2.tar.gz
(7.2 kB
view hashes)
Built Distribution
Close
Hashes for airflow_kaldea-0.0.2-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 2928eeaa86e50365341774f2447377aec76000d9fbf8ee4b6e11cbc6a3896b67 |
|
MD5 | 88ba8555a77bccccc9718c5c05fa0582 |
|
BLAKE2b-256 | 63f70f1e56fdd887e1adf378a98d29c073533b6b92f88df6e434c8b9c9ec9a82 |