qcg.pilotjob.receiver module¶

class qcg.pilotjob.receiver.ResponseStatus¶

Bases: enum.Enum

Request response status.

UNKNOWN = 1¶

ERROR = 2¶

SUCCESS = 3¶

class qcg.pilotjob.receiver.ValidateResponse¶

Bases: object

The response data.

result¶

status

Type:	ResponseStatus

msg¶

response message

Type:	str

request¶

request

Type:	Request

Initialize response.

error(err_msg)¶

Set response as an error.

Parameters:	err_msg (str) – response error message

success(request)¶

Set response as a success.

Parameters:	request (Request) – the original request

is_error¶

is an error response

Type:	bool

is_success¶

is a success response

Type:	bool

class qcg.pilotjob.receiver.Receiver(handler, ifaces)¶

Bases: object

The receiver listens for requests on input interfaces and passes requests to handlers (managers).

_ifaces¶

list of interfaces to listen for requests

Type:	list(Interface)

_tasks¶

list of tasks that listens on interfaces for incoming requests

Type:	list(asyncio.Future)

_zmq_address¶

address of the ZMQ input interface

Type:	str

_handler¶

object which handles incoming requests

Type:	Manager

_handlers¶

map of requests and handler functions

Type:	dict

finished¶

flag set by the handlers when receiving should be finished

Type:	bool

Initialize receiver.

Parameters:	handler – manager that handles requests ifaces (Interface[]) – list of interfaces

zmq_address¶

address of ZMQ interface

Type:	str

interfaces¶

list of input interfaces

Type:	list(Interface)

set_finish(finished)¶

Set finish flag.

If set to True the receiver should not accept any new requests and whole service should finish. The service will monitor this flag to know when receiver finished accepting requests.

Parameters:	finished (bool) – the finish flag

is_finished¶

the value of finish flag

Type:	bool

cancel_listeners()¶: Cancel all interface listeners.

run()¶

Start listening on interfaces.

This method creates asynchronic tasks and returns. To stop created tasks, method ‘stop’ must be called.

stop()¶: Stop all listening on interfaces.

generate_status_response()¶

Get current statistics from handler/manager.

Returns:	response with current statistics as a data
Return type:	Response