always wait for async insert except events and tags (#1015)

Author: dinmukhamedm

app-server/src/ch/events.rs

@@ -64,6 +64,7 @@ pub async fn insert_events(clickhouse: clickhouse::Client, events: Vec<CHEvent>)
     match ch_insert {
         Ok(mut ch_insert) => {
             let mut total_size_bytes = 0;
+            ch_insert = ch_insert.with_option("wait_for_async_insert", "0");
             for event in events {
                 ch_insert.write(&event).await?;
                 total_size_bytes += event.size_bytes as usize;

app-server/src/ch/tags.rs

@@ -90,6 +90,7 @@ pub async fn insert_tags_batch(client: clickhouse::Client, tags: &[SpanTag]) ->
     let ch_insert = client.insert("tags");
     match ch_insert {
         Ok(mut ch_insert) => {
+            ch_insert = ch_insert.with_option("wait_for_async_insert", "0");
             for span_tag in tags {
                 let id = Uuid::new_v4();
                 let tag = CHTag::new(

app-server/src/main.rs

@@ -471,7 +471,7 @@ fn main() -> anyhow::Result<()> {
         .with_user(clickhouse_user)
         .with_database("default")
         .with_option("async_insert", "1")
-        .with_option("wait_for_async_insert", "0");
+        .with_option("wait_for_async_insert", "1");
 
     let clickhouse = match clickhouse_password {
         Ok(password) => clickhouse_client.with_password(password),