Make udfs field optional in REST API

ArroyoSystems · Aug 15, 2023 · 0de2ce3 · 0de2ce3
1 parent 2cb5ac2
commit 0de2ce3
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 3 deletions.
diff --git a/arroyo-api/src/pipelines.rs b/arroyo-api/src/pipelines.rs
@@ -322,6 +322,7 @@ pub async fn validate_pipeline(
         parallelism: 1,
         udfs: validate_pipeline_post
             .udfs
+            .unwrap_or(vec![])
             .into_iter()
             .map(|u| CreateUdf {
                 language: 0,
@@ -389,6 +390,7 @@ pub async fn post_pipeline(
             parallelism: pipeline_post.parallelism,
             udfs: pipeline_post
                 .udfs
+                .unwrap_or(vec![])
                 .into_iter()
                 .map(|u| CreateUdf {
                     language: 0,

diff --git a/arroyo-rpc/src/types.rs b/arroyo-rpc/src/types.rs
@@ -7,15 +7,15 @@ use utoipa::ToSchema;
 #[serde(rename_all = "camelCase")]
 pub struct ValidatePipelinePost {
     pub query: String,
-    pub udfs: Vec<Udf>,
+    pub udfs: Option<Vec<Udf>>,
 }
 
 #[derive(Serialize, Deserialize, Clone, Debug, ToSchema)]
 #[serde(rename_all = "camelCase")]
 pub struct PipelinePost {
     pub name: String,
     pub query: String,
-    pub udfs: Vec<Udf>,
+    pub udfs: Option<Vec<Udf>>,
     pub preview: Option<bool>,
     pub parallelism: u64,
 }

diff --git a/integ/src/main.rs b/integ/src/main.rs
@@ -187,7 +187,7 @@ pub async fn main() {
                 by hop(interval '2 seconds', interval '10 seconds')",
                 source_name
             ),
-            udfs: vec![],
+            udfs: None,
         },
     )
     .await