aiida.brokers package

Subpackages

• aiida.brokers.rabbitmq package
  • Submodules
    • RabbitmqBroker
      • RabbitmqBroker.__annotations__
      • RabbitmqBroker.__init__()
      • RabbitmqBroker.__module__
      • RabbitmqBroker.__str__()
      • RabbitmqBroker._create_communicator()
      • RabbitmqBroker.check_rabbitmq_version()
      • RabbitmqBroker.close()
      • RabbitmqBroker.get_communicator()
      • RabbitmqBroker.get_rabbitmq_version()
      • RabbitmqBroker.get_url()
      • RabbitmqBroker.is_rabbitmq_version_supported()
      • RabbitmqBroker.iterate_tasks()
    • ManagementApiConnectionError
      • ManagementApiConnectionError.__module__
    • RabbitmqManagementClient
      • RabbitmqManagementClient.__dict__
      • RabbitmqManagementClient.__init__()
      • RabbitmqManagementClient.__module__
      • RabbitmqManagementClient.__weakref__
      • RabbitmqManagementClient.format_url()
      • RabbitmqManagementClient.is_connected
      • RabbitmqManagementClient.request()
    • detect_rabbitmq_config()
    • get_launch_queue_name()
    • get_message_exchange_name()
    • get_rmq_url()
    • get_task_exchange_name()

Submodules

Interface for a message broker that facilitates communication with and between process runners.

class aiida.brokers.broker.Broker(profile: Profile)

Bases: object

Interface for a message broker that facilitates communication with and between process runners.

__dict__ = mappingproxy({'__module__': 'aiida.brokers.broker', '__doc__': 'Interface for a message broker that facilitates communication with and between process runners.', '__init__': <function Broker.__init__>, 'get_communicator': <function Broker.get_communicator>, 'iterate_tasks': <function Broker.iterate_tasks>, 'close': <function Broker.close>, '__dict__': <attribute '__dict__' of 'Broker' objects>, '__weakref__': <attribute '__weakref__' of 'Broker' objects>, '__annotations__': {}})

__init__(profile: Profile) → None

Construct a new instance.

Parameters:

profile – The profile.

__module__ = 'aiida.brokers.broker'

__weakref__

list of weak references to the object

abstract close()

Close the broker.

abstract get_communicator()

Return an instance of kiwipy.Communicator.

abstract iterate_tasks()

Return an iterator over the tasks in the launch queue.