Transform airflow Library
Project description
Transform Airflow
Install:
pip install transform-airflow
Available Operators:
- MaterializeOperator
- materialization_name: str
- start_time: Optional[str]
- end_time: Optional[str]
- model_key_id: Optional[int]=None
- output_table: Optional[str]=None
- force: bool=False
Creating DAG:
from transform_airflow.operators import MaterializeOperator
# Init DAG
my_dag = DAG("my_dag_name")
# Associate task with DAG
op = MaterializeOperator(
task_id=task_id,
materialization_name="test",
start_time="2021-01-01",
end_time="2021-01-10",
)
# Perform any dependency structuring on tasks
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
Close
Hashes for transform-airflow-0.0.8rc0.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | f52b052dab8e3dc9ff12f414ee88421a53e3b7541410d8c3e35cf67539732de8 |
|
MD5 | d6cacf9ed2a1163fe5a9b053d19f9163 |
|
BLAKE2b-256 | cabad66d9ca3ecc99615358a42f2398e035ad9305cbbdbf1cd67cd29fc6c5d42 |