fn parse_flush_flow( params: &[ValueRef<'_>], query_ctx: &QueryContextRef, ) -> Result<(String, String)>