gzdZddlZddlmZddlmZmZddlmZm Z ej e Z GddeZ dS) zAThis module implements the job class used for AerBackend objects.N)JobV1) JobStatusJobError)DEFAULT_EXECUTORrequires_submitceZdZdZ d fd ZdZed dZedZedZ dZ d Z d Z xZ S) AerJobz AerJob class for Aer Simulators.Nct||||_||_||_||_|pt |_d|_dS)aInitializes the asynchronous job. Args: backend(AerBackend): the backend used to run the job. job_id(str): a unique id in the context of the backend used to run the job. fn(function): a callable function to execute qobj on backend. This should usually be a bound :meth:`AerBackend._run()` method, with the signature `(qobj: QasmQobj, job_id: str) -> Result`. circuits(list of QuantumCircuit): circuits to execute. parameter_binds(list): parameters for circuits. run_options(dict): run_options to execute. executor(ThreadPoolExecutor): The executor to be used to submit the job. Raises: JobError: if no qobj and no circuits. N) super__init___fn _circuits_parameter_binds _run_optionsr _executor_future) selfbackendjob_idfncircuitsparameter_binds run_optionsexecutor __class__s L/granary/edev/quantum/lib/python3.11/site-packages/qiskit_aer/jobs/aerjob.pyr zAerJob.__init__sU6 &)))! /'!5%5 c|jtd|j|j|j|j|j|j|_dS)aSubmit the job to the backend for execution. Raises: QobjValidationError: if the JSON serialization of the Qobj passed during construction does not validate against the Qobj schema. JobError: if trying to re-submit the job. Nz#Aer job has already been submitted.) rrrsubmitrrrr_job_idrs rr z AerJob.submit@sQ < #@AA A~,, Hdnd&;T=NPTP\   rc8|j|S)aGet job result. The behavior is the same as the underlying concurrent Future objects, https://docs.python.org/3/library/concurrent.futures.html#future-objects Args: timeout (float): number of seconds to wait for results. Returns: qiskit.Result: Result object Raises: concurrent.futures.TimeoutError: if timeout occurred. concurrent.futures.CancelledError: if job cancelled before completed. )timeout)rresult)rr$s rr%z AerJob.resultNs$|""7"333rc4|jS)zAttempt to cancel the job.)rcancelr"s rr'z AerJob.cancelbs|""$$$rcL|jr tj}n}|jr tj}nW|jr2|j tjn tj }n tj }|S)aGets the status of the job by querying the Python's future Returns: JobStatus: The current JobStatus Raises: JobError: If the future is in unexpected state concurrent.futures.TimeoutError: if timeout occurred. ) rrunningrRUNNING cancelled CANCELLEDdone exceptionDONEERROR INITIALIZING)r_statuss rstatusz AerJob.statusgs <   ! ! -'GG \ # # % % -)GG \    -(, (>(>(@(@(HinnioGG  ,Grc|jS)z5Return the instance of the backend used for this job.)_backendr"s rrzAerJob.backends }rc|jS)zReturn the list of QuantumCircuit submitted for this job. Returns: list of QuantumCircuit: the list of QuantumCircuit submitted for this job. )rr"s rrzAerJob.circuitss ~rc|jS)z Return the executor for this job)rr"s rrzAerJob.executors ~r)NNNN)N)__name__ __module__ __qualname____doc__r r rr%r'r3rrr __classcell__)rs@rr r s**!!!!!!F    444_4&%%_%_2rr )r;loggingqiskit.providersrJobrrutilsrr getLoggerr8LOGGERr rrrDsHG))))))0000000044444444  8 $ $uuuuuSuuuuur