Merge pull request #1011 from muzarski/toolchain_version

CI: fix issues related to `[tokio::test]`/`[ntest::timeout]` attributes and tablets with LWT

Author: Lorak-mmk

.github/workflows/rust.yml

@@ -26,6 +26,12 @@ jobs:
       run: |
         sudo sh -c "echo 2097152 >> /proc/sys/fs/aio-max-nr"
         docker compose -f test/cluster/docker-compose.yml up -d --wait
+    - name: Print rustc version
+      run: rustc --version
+    - name: Print rustfmt version
+      run: cargo fmt --version
+    - name: Print clippy version
+      run: cargo clippy --version
     - name: Format check
       run: cargo fmt --verbose --all -- --check
     - name: Clippy check

.github/workflows/tablets.yml

@@ -10,13 +10,22 @@ futures = "0.3.6"
 openssl = "0.10.32"
 rustyline = "9"
 rustyline-derive = "0.6"
-scylla = {path = "../scylla", features = ["ssl", "cloud", "chrono", "time", "num-bigint-03", "num-bigint-04", "bigdecimal-04"]}
-tokio = {version = "1.1.0", features = ["full"]}
-tracing = { version = "0.1.25" , features = ["log"] }
+scylla = { path = "../scylla", features = [
+    "ssl",
+    "cloud",
+    "chrono",
+    "time",
+    "num-bigint-03",
+    "num-bigint-04",
+    "bigdecimal-04",
+] }
+# FIXME: Remove <1.38 once https://github.com/tokio-rs/tokio/issues/6610 is fixed
+tokio = { version = ">=1.34, <1.38", features = ["full"] }
+tracing = { version = "0.1.25", features = ["log"] }
 tracing-subscriber = { version = "0.3.14", features = ["env-filter"] }
 chrono = { version = "0.4", default-features = false }
 time = { version = "0.3.22" }
-uuid = { version = "1.0", features = ["v1"]}
+uuid = { version = "1.0", features = ["v1"] }
 tower = "0.4"
 stats_alloc = "0.1"
 clap = { version = "3.2.4", features = ["derive"] }

examples/Cargo.toml

@@ -13,7 +13,8 @@ license = "MIT OR Apache-2.0"
 scylla-macros = { version = "0.5.0", path = "../scylla-macros" }
 byteorder = "1.3.4"
 bytes = "1.0.1"
-tokio = { version = "1.12", features = ["io-util", "time"] }
+# FIXME: Remove <1.38 once https://github.com/tokio-rs/tokio/issues/6610 is fixed
+tokio = { version = ">=1.34, <1.38", features = ["io-util", "time"] }
 secrecy = { version = "0.7.0", optional = true }
 snap = "1.0"
 uuid = "1.0"

scylla-cql/Cargo.toml

@@ -17,7 +17,8 @@ scylla-cql = { version = "0.2.0", path = "../scylla-cql" }
 byteorder = "1.3.4"
 bytes = "1.2.0"
 futures = "0.3.6"
-tokio = { version = "1.12", features = [
+# FIXME: Remove <1.38 once https://github.com/tokio-rs/tokio/issues/6610 is fixed
+tokio = { version = ">=1.34, <1.38", features = [
     "net",
     "time",
     "io-util",
@@ -38,7 +39,8 @@ rand = "0.8.5"
 assert_matches = "1.5.0"
 ntest = "0.9.0"
 tracing-subscriber = { version = "0.3.14", features = ["env-filter"] }
-tokio = { version = "1.12", features = ["signal"] }
+# FIXME: Remove <1.38 once https://github.com/tokio-rs/tokio/issues/6610 is fixed
+tokio = { version = ">=1.34, <1.38", features = ["signal"] }
 
 [lints.rust]
 unreachable_pub = "warn"

scylla-proxy/Cargo.toml

@@ -47,7 +47,8 @@ bytes = "1.0.1"
 futures = "0.3.6"
 hashbrown = "0.14"
 histogram = "0.6.9"
-tokio = { version = "1.34", features = [
+# FIXME: Remove <1.38 once https://github.com/tokio-rs/tokio/issues/6610 is fixed
+tokio = { version = ">=1.34, <1.38", features = [
     "net",
     "time",
     "io-util",
@@ -83,8 +84,9 @@ num-bigint-04 = { package = "num-bigint", version = "0.4" }
 bigdecimal-04 = { package = "bigdecimal", version = "0.4" }
 scylla-proxy = { version = "0.0.3", path = "../scylla-proxy" }
 ntest = "0.9.0"
-criterion = "0.4"                                                      # Note: v0.5 needs at least rust 1.70.0
-tokio = { version = "1.27", features = ["test-util"] }
+criterion = "0.4"                                              # Note: v0.5 needs at least rust 1.70.0
+# FIXME: Remove <1.38 once https://github.com/tokio-rs/tokio/issues/6610 is fixed
+tokio = { version = ">=1.34, <1.38", features = ["test-util"] }
 tracing-subscriber = { version = "0.3.14", features = ["env-filter"] }
 assert_matches = "1.5.0"
 rand_chacha = "0.3.1"

scylla/Cargo.toml

@@ -2424,7 +2424,11 @@ async fn test_batch_lwts() {
     let session = create_new_session_builder().build().await.unwrap();
 
     let ks = unique_keyspace_name();
-    session.query(format!("CREATE KEYSPACE IF NOT EXISTS {} WITH REPLICATION = {{'class' : 'NetworkTopologyStrategy', 'replication_factor' : 1}}", ks), &[]).await.unwrap();
+    let mut create_ks = format!("CREATE KEYSPACE {} WITH REPLICATION = {{'class': 'NetworkTopologyStrategy', 'replication_factor': 1}}", ks);
+    if scylla_supports_tablets(&session).await {
+        create_ks += " and TABLETS = { 'enabled': false}";
+    }
+    session.query(create_ks, &[]).await.unwrap();
     session.use_keyspace(ks.clone(), false).await.unwrap();
 
     session

scylla/src/transport/session_test.rs

@@ -1,5 +1,6 @@
 use crate::utils::{setup_tracing, test_with_3_node_cluster};
 use scylla::retry_policy::FallthroughRetryPolicy;
+use scylla::test_utils::scylla_supports_tablets;
 use scylla::test_utils::unique_keyspace_name;
 use scylla::transport::session::Session;
 use scylla::{ExecutionProfile, SessionBuilder};
@@ -68,7 +69,11 @@ async fn if_lwt_optimisation_mark_offered_then_negotiatied_and_lwt_routed_optima
 
         // Create schema
         let ks = unique_keyspace_name();
-        session.query(format!("CREATE KEYSPACE IF NOT EXISTS {} WITH REPLICATION = {{'class' : 'NetworkTopologyStrategy', 'replication_factor' : 3}}", ks), &[]).await.unwrap();
+        let mut create_ks = format!("CREATE KEYSPACE IF NOT EXISTS {} WITH REPLICATION = {{'class' : 'NetworkTopologyStrategy', 'replication_factor' : 3}}", ks);
+        if scylla_supports_tablets(&session).await {
+            create_ks += " and TABLETS = { 'enabled': false}";
+        }
+        session.query(create_ks, &[]).await.unwrap();
         session.use_keyspace(ks, false).await.unwrap();
 
         session

scylla/tests/integration/lwt_optimisation.rs

@@ -479,9 +479,12 @@ async fn test_tablet_feedback_not_sent_for_unprepared_queries() {
 /// for every tablet.
 /// After that it sends 100 queries fro each tablet and verifies that only 1 shard on 1 node
 /// recevied requests for a given tablet.
+///
+/// TODO: Remove #[ignore] once LWTs are supported with tablets.
 #[cfg(not(scylla_cloud_tests))]
 #[tokio::test]
 #[ntest::timeout(30000)]
+#[ignore]
 async fn test_lwt_optimization_works_with_tablets() {
     setup_tracing();
     const TABLET_COUNT: usize = 16;