pub(crate) async fn gen_create_mv_graph(
handler_args: HandlerArgs,
name: ObjectName,
query: BoundQuery,
dependent_relations: HashSet<TableId>,
dependent_udfs: HashSet<FunctionId>,
columns: Vec<Ident>,
emit_mode: Option<EmitMode>,
) -> Result<(TableCatalog, PbStreamFragmentGraph, HashSet<u32>, Option<String>), RwError>