Another blindfix attempt on UNKNOWN_DATABASE problem

reducing TCP keepalive timeout to 1 second
reducing number of parallel stateless tests batches

Author: Enmk

ci/jobs/functional_tests.py

@@ -70,7 +70,7 @@ def run_tests(
 ):
     assert not (no_parallel and no_sequiential)
     test_output_file = f"{temp_dir}/test_result.txt"
-    nproc = int(Utils.cpu_count() / 2)
+    nproc = int(Utils.cpu_count() / 8)
     if batch_num and batch_total:
         extra_args += (
             f" --run-by-hash-total {batch_total} --run-by-hash-num {batch_num-1}"

ci/praktika/runner.py

@@ -274,7 +274,7 @@ def _run(self, workflow, job, docker="", no_docker=False, param=None, test=""):
                 "docker ps -a --format '{{.Names}}' | grep -q praktika && docker rm -f praktika",
                 verbose=True,
             )
-            cmd = f"docker run --rm --name praktika {'--user $(id -u):$(id -g)' if not from_root else ''} -e PYTHONPATH='.:./ci' --volume ./:{current_dir} --workdir={current_dir} {' '.join(settings)} {docker} {job.command}"
+            cmd = f"docker run --rm --sysctl net.ipv4.tcp_keepalive_time=1 --name praktika {'--user $(id -u):$(id -g)' if not from_root else ''} -e PYTHONPATH='.:./ci' --volume ./:{current_dir} --workdir={current_dir} {' '.join(settings)} {docker} {job.command}"
         else:
             cmd = job.command
             python_path = os.getenv("PYTHONPATH", ":")

tests/clickhouse-test

@@ -2010,13 +2010,14 @@ class TestCase:
             )
 
         # pylint:disable-next=consider-using-with; TODO: fix
-        with autokill_subprocess(Popen(command, shell=True, env=tests_env, start_new_session=True)) as proc:
-            try:
-                proc.wait(args.timeout)
-            except subprocess.TimeoutExpired:
-                # Whether the test timed out will be decided later
-                print(f"!!! Timeout: {args.timeout}")
-                pass
+        with Popen(command, shell=True, env=tests_env, start_new_session=True) as proc:
+            with autokill_subprocess(proc) as proc:
+                try:
+                    proc.wait(args.timeout)
+                except subprocess.TimeoutExpired:
+                    # Whether the test timed out will be decided later
+                    print(f"!!! Timeout: {args.timeout}")
+                    pass
 
         total_time = (datetime.now() - start_time).total_seconds()