Class RMQStatusUpdate¶

Defined in File orchestrator.py

Class Documentation¶

class RMQStatusUpdate¶

@brief a dataflow step to inform (eventually) stagers about the existence of new models. To do so it listens to
    the ``i_queue`` of the TrainJobScheduler and publishes messages to a RabbitMQ queue.

Public Functions

__init__(self, Queue i_queue, str host, int port, str vhost, str user, str password, str cert, str publish_queue, signals=[signal.SIGTERM, signal.SIGINT, signal.SIGUSR1])¶

__call__(self)¶

Public Members

producer¶

publish_queue¶

i_queue¶