No project description provided
Project description
# Airflow Docker Helper
[![CircleCI](https://circleci.com/gh/huntcsg/airflow-docker-helper/tree/master.svg?style=svg)](https://circleci.com/gh/huntcsg/airflow-docker-helper/tree/master) [![Codacy Badge](https://api.codacy.com/project/badge/Grade/3e2f177d8c314f43903fe9d9b7af0647)](https://www.codacy.com/app/fool.of.god/airflow-docker-helper?utm_source=github.com&utm_medium=referral&utm_content=huntcsg/airflow-docker-helper&utm_campaign=Badge_Grade) [![codecov](https://codecov.io/gh/huntcsg/airflow-docker-helper/branch/master/graph/badge.svg)](https://codecov.io/gh/huntcsg/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
```bash
pip install airflow-docker-helper
```
## Usage
### Sensor
```python
from airflow_docker_helper import client
if sensed:
client.sensor(True)
else:
client.sensor(False)
```
### Short Circuit
```python
from airflow_docker_helper import client
if should_short_circuit:
client.short_circuit()
```
### Branching
You can pass a list...
```python
from airflow_docker_helper import client
branch_to_task_ids = ['foo', 'bar']
client.branch_to_tasks(branch_to_task_ids)
```
... or a string.
```python
from airflow_docker_helper import client
client.branch_to_tasks('some-other-task')
```
[![CircleCI](https://circleci.com/gh/huntcsg/airflow-docker-helper/tree/master.svg?style=svg)](https://circleci.com/gh/huntcsg/airflow-docker-helper/tree/master) [![Codacy Badge](https://api.codacy.com/project/badge/Grade/3e2f177d8c314f43903fe9d9b7af0647)](https://www.codacy.com/app/fool.of.god/airflow-docker-helper?utm_source=github.com&utm_medium=referral&utm_content=huntcsg/airflow-docker-helper&utm_campaign=Badge_Grade) [![codecov](https://codecov.io/gh/huntcsg/airflow-docker-helper/branch/master/graph/badge.svg)](https://codecov.io/gh/huntcsg/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
```bash
pip install airflow-docker-helper
```
## Usage
### Sensor
```python
from airflow_docker_helper import client
if sensed:
client.sensor(True)
else:
client.sensor(False)
```
### Short Circuit
```python
from airflow_docker_helper import client
if should_short_circuit:
client.short_circuit()
```
### Branching
You can pass a list...
```python
from airflow_docker_helper import client
branch_to_task_ids = ['foo', 'bar']
client.branch_to_tasks(branch_to_task_ids)
```
... or a string.
```python
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.1.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | f85015a200fda2ed410eeeccbb4b0bb4dac4057554b7569626b17a3ddc0ef384 |
|
MD5 | 145ab87d86214b9498611c293169178b |
|
BLAKE2b-256 | eabf7c5f42873740e8995aac4e06d6cc0c32a798d620947f6291fc18bf93aa6b |
Close
Hashes for airflow_docker_helper-0.1.1-py2.py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 8afc7da54242ab6e1a55048ac42c06166f71ede11e5aaca53f24d031977d949b |
|
MD5 | f9553ef2b19a482e51f1fac1875c180b |
|
BLAKE2b-256 | 26b37a0b6f3f6d7aea7045688ac0b6a7e1ab084968f5f11fa908d72ecf0d66d7 |