chore: bump tokio from 1.26.0 to 1.35.0 (#13967)

* chore: bump tokio from 1.26.0 to 1.35.0

* fix 07_0002_insert_with_stage_deduplicate.sh test add wait_time_secs to wait the curl return

Author: BohuTANG

Cargo.lock

@@ -196,7 +196,7 @@ reqwest = { version = "0.11.19", default-features = false, features = [
 ] }
 
 # runtime
-tokio = { version = "1.26.0", features = ["full"] }
+tokio = { version = "1.35.0", features = ["full"] }
 
 # backtrace
 async-backtrace = { git = "https://github.com/zhang2014/async-backtrace.git", rev = "e7e1b5f" }

Cargo.toml

@@ -15,8 +15,6 @@ name = "databend"
 crate-type = ["cdylib"]
 
 [dependencies]
-pyo3 = { version = "0.19.1", features = ["extension-module", "abi3", "abi3-py37"] }
-uuid = { version = "1.1.2" }
 # Workspace dependencies
 arrow = { workspace = true }
 arrow-schema = { workspace = true }
@@ -33,6 +31,8 @@ databend-query = { path = "../query/service", features = [
 ], default-features = false }
 
 # # Crates.io dependencies
-ctor = "0.1.26"
-tokio = { version = "1.24", features = ["macros", "rt", "rt-multi-thread", "sync"] }
+ctor = "0.2.5"
+pyo3 = { version = "0.19.1", features = ["extension-module", "abi3", "abi3-py37"] }
+tokio = { workspace = true, features = ["macros", "rt", "rt-multi-thread", "sync"] }
 tokio-stream = "0.1.10"
+uuid = { version = "1.1.2" }

src/bendpy/Cargo.toml

@@ -24,12 +24,35 @@ echo "CREATE STAGE s1 FILE_FORMAT = (TYPE = CSV)" | $BENDSQL_CLIENT_CONNECT
 echo "list @s1" | $BENDSQL_CLIENT_CONNECT | awk '{print $1}'
 
 ## Insert with stage use http API
-curl -s -u root: -XPOST "http://localhost:${QUERY_HTTP_HANDLER_PORT}/v1/query" --header 'Content-Type: application/json' --header 'X-DATABEND-DEDUPLICATE-LABEL: insert1' -d '{"sql": "insert into sample (Id, City, Score) values", "stage_attachment": {"location": "@s1/sample.csv"}}' | jq -r '.stats.scan_progress.bytes, .stats.write_progress.bytes, .error'
+curl -s -u root: -XPOST "http://localhost:${QUERY_HTTP_HANDLER_PORT}/v1/query" \
+  --header 'Content-Type: application/json' \
+  --header 'X-DATABEND-DEDUPLICATE-LABEL: insert1' \
+  -d '{
+    "sql": "insert into sample (Id, City, Score) values",
+    "stage_attachment": {
+      "location": "@s1/sample.csv"
+    },
+    "pagination": {
+      "wait_time_secs": 3
+    }
+  }' | jq -r '.stats.scan_progress.bytes, .stats.write_progress.bytes, .error'
 
 echo "select * from sample" | $BENDSQL_CLIENT_CONNECT
 
 ## Insert again with the same deduplicate_label will have no effect
-curl -s -u root: -XPOST "http://localhost:${QUERY_HTTP_HANDLER_PORT}/v1/query" --header 'Content-Type: application/json' --header 'X-DATABEND-DEDUPLICATE-LABEL: insert1' -d '{"sql": "insert into sample (Id, City, Score) values", "stage_attachment": {"location": "@s1/sample.csv"}}' | jq -r '.stats.scan_progress.bytes, .stats.write_progress.bytes, .error'
+curl -s -u root: -XPOST "http://localhost:${QUERY_HTTP_HANDLER_PORT}/v1/query" \
+  --header 'Content-Type: application/json' \
+  --header 'X-DATABEND-DEDUPLICATE-LABEL: insert1' \
+  -d '{
+    "sql": "insert into sample (Id, City, Score) values",
+    "stage_attachment": {
+      "location": "@s1/sample.csv"
+    },
+    "pagination": {
+      "wait_time_secs": 3
+    }
+  }' | jq -r '.stats.scan_progress.bytes, .stats.write_progress.bytes, .error'
+
 
 echo "select * from sample" | $BENDSQL_CLIENT_CONNECT