Skip to content

mis.pipeline.execution

source module mis.pipeline.execution

Classes

source enum Status()

Bases : str, Enum

Attributes

  • IN_PROGRESS

  • SUCCESS

  • FAILURE

source class Execution()

Bases : abc.ABC, Generic[Result]

A task being sent to a quantum device and which may need some time before it is completed.

Methods

  • result

  • wait

  • status

  • map — Apply a transformation to the result once it is complete.

  • success — Shortcut to return a result that has already succeeded.

source method Execution.result() → Result

source async method Execution.wait(self) → Result

source method Execution.status() → Status

source method Execution.map(transform: Callable[[Result], Transformed]) → Execution[Transformed]

Apply a transformation to the result once it is complete.

source classmethod Execution.success(result: Result) → Execution[Result]

Shortcut to return a result that has already succeeded.

source class WaitingExecution(sleep_sec: int)

Bases : Execution[Result]

A task being sent to a quantum device and which definitely needs some time before it is completed.

Unless you're implementing new executors, you're probably not interested in this class.

Methods

source async method WaitingExecution.wait(self) → Result

source class MappedExecution(origin: Execution[Result], transform: Callable[[Result], Transformed])

Bases : Execution[Transformed]

The result of calling map on an Execution.

Unless you're implementing new executors, you're probably not interested in this class.

Methods

source method MappedExecution.result() → Transformed

source method MappedExecution.status() → Status

source async method MappedExecution.wait(self) → Transformed

source class SuccessfulExecution(result: Result)

Bases : Execution[Result]

An execution that is already completed.

Unless you're implementing new executors, you're probably not interested in this class.

Methods

source method SuccessfulExecution.status() → Status

source async method SuccessfulExecution.wait(self) → Result

source method SuccessfulExecution.result() → Result

source method SuccessfulExecution.map(transform: Callable[[Result], Transformed]) → Execution[Transformed]