pub async fn create_pipe(
__arg0: State<Arc<ApiState>>,
__arg1: Json<CreatePipeRequest>,
) -> Result<Json<MutationResponse>, Json<ErrorResponse>>pub async fn create_pipe(
__arg0: State<Arc<ApiState>>,
__arg1: Json<CreatePipeRequest>,
) -> Result<Json<MutationResponse>, Json<ErrorResponse>>