astro.airflow.datasets
Module Contents
Functions
|
Extract inlets and outlets from kwargs if users have passed it. If not, set input datasets as inlets and |
Attributes
- astro.airflow.datasets.DATASET_SUPPORT = True
- astro.airflow.datasets.kwargs_with_datasets(kwargs=None, input_datasets=None, output_datasets=None)
Extract inlets and outlets from kwargs if users have passed it. If not, set input datasets as inlets and set output dataset as outlets
- Parameters:
kwargs (dict | None) –
input_datasets (list[airflow.datasets.Dataset] | airflow.datasets.Dataset | None) –
output_datasets (list[airflow.datasets.Dataset] | airflow.datasets.Dataset | None) –