diff --git a/src/ga_qas.py b/src/ga_qas.py index 2d68b0f..28e1417 100755 --- a/src/ga_qas.py +++ b/src/ga_qas.py @@ -82,6 +82,12 @@ def run_ga_qas( mutation_rate: float, seed: int, ) -> list[tuple[int, int, int, int, int, float, float, float]]: + + print( + f"running GA QAS {seed} with {qubits} qubits, {depth} depth, for {generations} generations of size {generation_size}, with {parent_amount} parents and {mutation_rate:.3f} mutation rate", + file=sys.stderr, + ) + seed_rng = random.Random(seed) initial_population: list[QuantumCircuit] = ( Stream( @@ -159,7 +165,6 @@ def run_ga_qas( best_circuits.append(offspring[0]) population = offspring print(f"finished seed {seed}", file=sys.stderr) - print(f"finished seed {seed}", flush=True, file=sys.stdout) return return_data @@ -168,7 +173,7 @@ def run_from_point(pnt: tuple[tuple[int, int, int, int, float], int]): return run_ga_qas( point[0], point[1], - 2, + 20, point[2], point[3], point[4], diff --git a/src/qas_flow/funcs.py b/src/qas_flow/funcs.py index a1575e7..eb0cf64 100644 --- a/src/qas_flow/funcs.py +++ b/src/qas_flow/funcs.py @@ -34,20 +34,15 @@ def par_map(stream: Stream[T], fn: Callable[[T], U], cores: int = 0) -> Stream[U for _ in range(inflight): x = next(it) - print(f"adding {x}") pending.add(ex.submit(fn, x)) - print(f"added stuff to pending {pending}") while True: done, pending = wait(pending, return_when=FIRST_COMPLETED) - print(f"wait finished, {done}, {pending}") for fut in done: print(f"yielding: {fut}", file=sys.stderr) - print(fut.result()) yield fut.result() x = next(it) - print(f"adding {x}") pending.add(ex.submit(fn, x)) return Stream(gen())