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

Metadata

Release files for transform-airflow 0.0.7

For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.

Source distribution (sdist)

Source distribution for transform-airflow 0.0.7
File	Size	Uploaded
transform-airflow-0.0.7.tar.gz	3.0 kB	Feb 22, 2022	Details

Release files / transform-airflow-0.0.7.tar.gz

Download URL	transform-airflow-0.0.7.tar.gz
Size	3.0 kB
Tags	Source
SHA-256 checksum How to use checksums	`91e9eee31da367a4795cd15a6035bac80647e879bd776111ee03a83203bef276`
BLAKE2b-256 checksum How to use checksums	`3ad784d44bf4772a2525ae2e33a0f3ca15ad8a49ccd7d125711619923370a9f4`
Upload date	Feb 22, 2022
Uploaded using Trusted Publishing? What is trusted publishing?	No
Uploaded via	`twine/3.8.0 pkginfo/1.8.2 readme-renderer/32.0 requests/2.27.1 requests-toolbelt/0.9.1 urllib3/1.26.8 tqdm/4.62.3 importlib-metadata/4.11.1 keyring/23.5.0 rfc3986/2.0.0 colorama/0.4.4 CPython/3.8.12`