astro.airflow.datasets

Module Contents

Functions

kwargs_with_datasets([kwargs, input_datasets, ...])

Extract inlets and outlets from kwargs if users have passed it. If not, set input datasets as inlets and

Attributes

DATASET_SUPPORT

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[Dataset] | Dataset | None) –

  • output_datasets (list[Dataset] | Dataset | None) –