A light sdk to be used by the operators in airflow-docker and in task code to participate in host/container communication.
Project description
Airflow Docker Helper
Description
A light sdk to be used by the operators in airflow-docker and in task code to participate in host/container communication.
Installation
pip install airflow-docker-helper
Usage
Sensor
from airflow_docker_helper import client
if sensed:
client.sensor(True)
else:
client.sensor(False)
Short Circuit
from airflow_docker_helper import client
if should_short_circuit:
client.short_circuit()
Branching
You can pass a list...
from airflow_docker_helper import client
branch_to_task_ids = ['foo', 'bar']
client.branch_to_tasks(branch_to_task_ids)
... or a string.
from airflow_docker_helper import client
client.branch_to_tasks('some-other-task')
Project details
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Close
Hashes for airflow-docker-helper-0.1.3.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | 2968cb212dca08b9321e26193b788e660807c026ff838a5cdd8239d0f611f8ed |
|
MD5 | 87ea2f95d5087f8ac4588e705eeba2c6 |
|
BLAKE2b-256 | 8f56255c770a23b889f0ff73a2dca359fde668dd6bdaf4ed23505aaed1b8fefc |
Close
Hashes for airflow_docker_helper-0.1.3-py2.py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 8f932e9e9ae6d7d21f87a43f3193a281b13ae8bdb5f3d837195f122db7aa834c |
|
MD5 | c42045ad5d0d96874aadb01c9ef2eead |
|
BLAKE2b-256 | 73dd8496fd4ea8f6b8d9fdb24b5492070961a62fe779ae866583a68f603c7ec9 |