feat: increase parallel workers for CHSHPhaseScan experiment and backend submission

Author: orangekame3

docs/examples/qpu/chsh_phase_scan_parallel.py

@@ -24,7 +24,7 @@ def main():
     )
 
     # Run experiment
-    result = exp.run_parallel(backend=backend, shots=1000, workers=2)
+    result = exp.run_parallel(backend=backend, shots=1000, workers=10)
 
     # Analyze results
     df = result.analyze()

src/oqtopus_experiments/backends/oqtopus_backend.py

@@ -485,6 +485,7 @@ def submit_parallel(
         disable_transpilation: bool = False,
         mitigation_info: dict[str, Any] | None = None,
         experiment_name: str | None = None,
+        workers: int = 4,
     ) -> list[str | None]:
         """
         Submit circuits in parallel to OQTOPUS cloud with parameter tracking
@@ -567,7 +568,7 @@ def submit_single_circuit(circuit_with_params):
             # Submit circuits in parallel with parameters
             job_ids: list[str | None] = [None] * len(circuits)
 
-            with ThreadPoolExecutor(max_workers=4) as executor:
+            with ThreadPoolExecutor(max_workers=workers) as executor:
                 # Create circuit-params-index tuples
                 circuit_tuples = [
                     (circuits[i], circuit_params[i], i) for i in range(len(circuits))

src/oqtopus_experiments/core/base_experiment.py

@@ -472,6 +472,7 @@ def run_parallel(
                     disable_transpilation,
                     mitigation_info,
                     experiment_name,
+                    workers=workers,
                 )
             else:
                 job_ids = backend.submit_parallel(
@@ -480,6 +481,7 @@ def run_parallel(
                     circuit_params,
                     disable_transpilation,
                     mitigation_info,
+                    workers=workers,
                 )
             print(f"Collecting {len(job_ids)} results")
             results = backend.collect_parallel(job_ids)