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

Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

transform-airflow-0.0.7.tar.gz (3.0 kB view details)

Uploaded Feb 22, 2022 Source

File details

Details for the file transform-airflow-0.0.7.tar.gz.

File metadata

Download URL: transform-airflow-0.0.7.tar.gz
Upload date: Feb 22, 2022
Size: 3.0 kB
Tags: Source
Uploaded using 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

File hashes

Hashes for transform-airflow-0.0.7.tar.gz
Algorithm	Hash digest
SHA256	`91e9eee31da367a4795cd15a6035bac80647e879bd776111ee03a83203bef276`
MD5	`fef89c9ccba4136cbdf6da58ada759f8`
BLAKE2b-256	`3ad784d44bf4772a2525ae2e33a0f3ca15ad8a49ccd7d125711619923370a9f4`