From e208b3ebc09ccf4da7f81bf7877f3d2fd7c7ea9f Mon Sep 17 00:00:00 2001
From: shubham <shubhamdixit863@gmail.com>
Date: Mon, 11 Dec 2023 13:48:43 +0530
Subject: [PATCH] fixed side input udf await

Signed-off-by: shubham <shubhamdixit863@gmail.com>
---
 examples/sideinput-udf/src/main.rs | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

diff --git a/examples/sideinput-udf/src/main.rs b/examples/sideinput-udf/src/main.rs
index 203ed34..65d581b 100644
--- a/examples/sideinput-udf/src/main.rs
+++ b/examples/sideinput-udf/src/main.rs
@@ -4,7 +4,6 @@ use std::path::Path;
 use tonic::{async_trait};
 use tokio::spawn;
 
-
 const DIR_PATH: &str = "/var/run/numaflow/sideinput.sock";
 struct UdfMapper {}
 #[async_trait]
@@ -20,21 +19,22 @@ impl Mapper for UdfMapper {
 }
 #[tokio::main]
 async fn main() -> std::result::Result<(), Box<dyn std::error::Error>> {
-    let udf_map=UdfMapper{};
-    start_uds_server(udf_map).await?;
-
     // Spawn the file watcher task
     spawn(async {
-        match file_watcher() {
+        match file_watcher().await {
             Ok(_) => println!("File watcher is running"),
             Err(e) => println!("File watcher error: {:?}", e),
         }
     });
+
+    let udf_map=UdfMapper{};
+    start_uds_server(udf_map).await?;
+
     Ok(())
 }
 
 
-fn file_watcher() -> Result<()>{
+async fn file_watcher() -> Result<()>{
     let mut watcher = notify::recommended_watcher(|res| {
         match res {
             Ok(event) => println!("event: {:?}", event),