def repeated_subdag()

in utils/glam_subdags/general.py [0:0]


def repeated_subdag(
    parent_dag_name,
    child_dag_name,
    default_args,
    schedule_interval,
    billing_project_id,
    table_project_id,
    dataset_id,
    fully_qualified_dataset_id,
    additional_params=None,
    num_partitions=5,
    date_partition_parameter="submission_date",
    docker_image="gcr.io/moz-fx-data-airflow-prod-88e0/bigquery-etl:latest",
    parallel=False,