def create_adaptive_backfill_dag()

in dags/map_reproducibility/internal_runs/backfill_dags.py [0:0]

• 11 lines of code
• 3 McCabe index (conditional complexity)

def create_adaptive_backfill_dag(
    dag_id: str,
    model_configs: Dict[str, Dict[str, Any]],
    start_date: datetime.datetime,
    dag_tags: Optional[List[str]] = None,
    schedule: Optional[str] = None,  # Default None for backfill
    test_run: bool = DEFAULT_TEST_RUN,
    backfill: bool = DEFAULT_BACKFILL,
    nightly_image_tag: str = DEFAULT_NIGHTLY_IMAGE_TAG,
    release_image_tag: str = DEFAULT_RELEASE_IMAGE_TAG,
    retries: int = 2,  # Number of retries for tasks