try to fix

Author: vgvoleg

tests/slo/src/jobs.py

@@ -31,17 +31,17 @@
 );
 """
 
-QUERY_READ_QUERY_TEMPLATE = """
-SELECT * FROM `{}` WHERE object_id = $object_id AND object_hash = Digest::NumericHash($object_id);
-"""
-
-QUERY_WRITE_QUERY_TEMPLATE = """
-UPSERT INTO `{}` (
-    object_id, object_hash, payload_str, payload_double, payload_timestamp
-) VALUES (
-    $object_id, Digest::NumericHash($object_id), $payload_str, $payload_double, $payload_timestamp
-);
-"""
+# QUERY_READ_QUERY_TEMPLATE = """
+# SELECT * FROM `{}` WHERE object_id = $object_id AND object_hash = Digest::NumericHash($object_id);
+# """
+
+# QUERY_WRITE_QUERY_TEMPLATE = """
+# UPSERT INTO `{}` (
+#     object_id, object_hash, payload_str, payload_double, payload_timestamp
+# ) VALUES (
+#     $object_id, Digest::NumericHash($object_id), $payload_str, $payload_double, $payload_timestamp
+# );
+# """
 
 logger = logging.getLogger(__name__)
 
@@ -187,7 +187,7 @@ def check_result(result):
 def run_read_jobs_query(args, driver, tb_name, max_id, metrics):
     logger.info("Start read jobs over query service")
 
-    read_q = QUERY_READ_QUERY_TEMPLATE.format(tb_name)
+    read_q = READ_QUERY_TEMPLATE.format(tb_name)
 
     read_limiter = RateLimiter(max_calls=args.read_rps, period=1)
     futures = []
@@ -308,7 +308,7 @@ def check_result(result):
 def run_write_jobs_query(args, driver, tb_name, max_id, metrics):
     logger.info("Start write jobs for query service")
 
-    write_q = QUERY_WRITE_QUERY_TEMPLATE.format(tb_name)
+    write_q = WRITE_QUERY_TEMPLATE.format(tb_name)
 
     write_limiter = RateLimiter(max_calls=args.write_rps, period=1)
     row_generator = RowGenerator(max_id)