airflow-docker-helper 0.1.3

A light sdk to be used by the operators in airflow-docker and in task code to participate in host/container communication.

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')