Class RequestProcessor¶

Defined in File orchestrator.py

Class Documentation¶

class RequestProcessor¶

@brief a dataflow step that reads a message from the AMSJobReceiverStage.

This step performs the following actions:
    1. Registers job-specification into the global known 'AvailableDomains'
    2. Updates the size of collected data in the candidate database

    and through a heuristic informs the next stage to scheudle jobs

Public Functions

__init__(self, Queue i_queue, Queue o_queue, AvailableDomains domains)¶

new_candidates(self, domain, size)¶

register_job_spec(self, str domain, dict spec)¶

@brief Updates the specification of jobs in the AvailableDomains

process_request(self, domain, data)¶

__call__(self)¶

Public Members

i_queue¶

o_queue¶

Protected Attributes

_domains¶