get_af_dag_args: Get airflow dag args

Description Usage Arguments Value

View source: R/airflow.R

Description

Get specified args (attributes) from all Airflow dags contained in dag_dir

Usage

1
2
get_af_dag_args(dag_dir = config::get()$dag_dir, args = c("start_date",
  "schedule_interval"))

Arguments

dag_dir

airflow dag directory

args

attributes to extract. NOTE: currently only extracts start_date and schedule_interval - needs generalization.

Value

data frame of the form (dag_id, dag_args)


misha-lisovich/laminar documentation built on May 23, 2019, 9:51 a.m.