Description:

transformairflow 0.0.7

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

License

For personal and professional use. You cannot resell or redistribute these repositories in their original state.

Share

• Share on Facebook
• Share on Twitter