def METHOD_NAME():
    dag = DAG(
        dag_id=DAG_ID,
        default_args=DAG_DEFAULT_ARGS,
        schedule="@weekly",
        catchup=False,
        tags=["database"],
        doc_md=__doc__,
        render_template_as_native_obj=True,
    )
    with dag:
        get_reports_tasks = []
        report_counts_by_media_type = {}
        for media_type in MEDIA_TYPES:
            get_reports = PythonOperator(
                task_id=f"get_pending_{media_type}_reports",
                python_callable=get_pending_report_counts,
                op_kwargs={
                    "db_conn_id": OPENLEDGER_API_CONN_ID,
                    "media_type": media_type,
                },
            )
            report_counts_by_media_type[media_type] = XCOM_PULL_TEMPLATE.format(
                get_reports.task_id, "return_value"
            )
            get_reports_tasks.append(get_reports)
        report_pending_reports = PythonOperator(
            task_id="report_pending_media_reports",
            python_callable=report_actionable_records,
            op_kwargs={"report_counts_by_media_type": report_counts_by_media_type},
        )
        get_reports_tasks >> report_pending_reports
    return dag