async def create_sync_dag(
    sync_id: UUID,
    dag: schemas.SyncDagCreate,
    db: AsyncSession = Depends(deps.get_db),
    current_user: User = Depends(deps.get_user),
):
    """Create a new DAG definition for a sync."""
    return await sync_dag.create_with_nodes_and_edges(db, obj_in=dag, current_user=current_user)
Create a new DAG definition for a sync.
backend/airweave/api/v1/endpoints/dag.py