async def initialize_dag(
    sync_id: UUID,
    db: AsyncSession = Depends(deps.get_db),
    current_user: User = Depends(deps.get_user),
) -> schemas.SyncDag:
    """Initialize a new DAG with source, entities, and destination."""
    dag = await dag_service.create_initial_dag(db, sync_id=sync_id, current_user=current_user)
    return dag
Initialize a new DAG with source, entities, and destination.
backend/airweave/api/v1/endpoints/dag.py