call run_sweep_async in parallel

Author: senecameeks

cirq-google/cirq_google/engine/processor_sampler.py

@@ -16,11 +16,16 @@
 
 import cirq
 import duet
+import concurrent.futures
+from typing import TypeVar, Generic
 
 if TYPE_CHECKING:
     import cirq_google as cg
 
 
+T = TypeVar("T")
+
+
 class ProcessorSampler(cirq.Sampler):
     """A wrapper around AbstractProcessor to implement the cirq.Sampler interface."""
 
@@ -76,6 +81,7 @@ async def run_batch_async(
         params_list: Optional[Sequence[cirq.Sweepable]] = None,
         repetitions: Union[int, Sequence[int]] = 1,
     ) -> Sequence[Sequence['cg.EngineResult']]:
+        print("outer")
         return cast(
             Sequence[Sequence['cg.EngineResult']],
             await super().run_batch_async(programs, params_list, repetitions),