code review

golemcloud · Oct 2, 2024 · e4f4e22 · e4f4e22
1 parent 8476cc6
commit e4f4e22
Show file tree

Hide file tree

Showing 4 changed files with 16 additions and 16 deletions.
diff --git a/golem-common/src/config.rs b/golem-common/src/config.rs
@@ -479,6 +479,7 @@ pub struct CassandraConfig {
     pub username: Option<String>,
     pub password: Option<String>,
 }
+
 fn default_cassandra_keyspace() -> String {
     String::from("__golem")
 }

diff --git a/golem-test-framework/src/config/cli.rs b/golem-test-framework/src/config/cli.rs
@@ -1085,6 +1085,7 @@ impl TestDependencies for CliTestDependencies {
     fn worker_executor_cluster(&self) -> Arc<dyn WorkerExecutorCluster + Send + Sync + 'static> {
         self.worker_executor_cluster.clone()
     }
+
     fn cassandra(
         &self,
     ) -> Arc<dyn crate::components::cassandra::Cassandra + Send + Sync + 'static> {

diff --git a/golem-test-framework/src/config/env.rs b/golem-test-framework/src/config/env.rs
@@ -525,6 +525,7 @@ impl TestDependencies for EnvBasedTestDependencies {
     fn worker_executor_cluster(&self) -> Arc<dyn WorkerExecutorCluster + Send + Sync + 'static> {
         self.worker_executor_cluster.clone()
     }
+
     fn cassandra(&self) -> Arc<dyn Cassandra + Send + Sync + 'static> {
         self.cassandra.clone()
     }

diff --git a/golem-worker-executor-base/src/cassandra.rs b/golem-worker-executor-base/src/cassandra.rs
@@ -83,13 +83,12 @@ impl CassandraSession {
             .query_unpaged(
                 Query::new(format!(
                     r#"
-            CREATE TABLE IF NOT EXISTS {}.kv_store (
-                namespace TEXT,
-                key TEXT,
-                value BLOB,
-                PRIMARY KEY (namespace, key)
-            );
-        "#,
+                CREATE TABLE IF NOT EXISTS {}.kv_store (
+                    namespace TEXT,
+                    key TEXT,
+                    value BLOB,
+                    PRIMARY KEY (namespace, key)
+                );"#,
                     self.keyspace
                 )),
                 &[],
@@ -101,13 +100,12 @@ impl CassandraSession {
             .query_unpaged(
                 Query::new(format!(
                     r#"
-            CREATE TABLE IF NOT EXISTS {}.kv_sets (
-                namespace TEXT,
-                key TEXT,
-                value BLOB,
-                PRIMARY KEY ((namespace, key), value)
-            );
-        "#,
+                CREATE TABLE IF NOT EXISTS {}.kv_sets (
+                    namespace TEXT,
+                    key TEXT,
+                    value BLOB,
+                    PRIMARY KEY ((namespace, key), value)
+                );"#,
                     self.keyspace
                 )),
                 &[],
@@ -125,8 +123,7 @@ impl CassandraSession {
                     score DOUBLE,
                     value BLOB,
                     PRIMARY KEY ((namespace, key), score, value)
-                );
-        "#,
+                );"#,
                     self.keyspace
                 )),
                 &[],