ska_sdp_batchlet_plugins.consumers.sdp_configuration_db module

class ska_sdp_batchlet_plugins.consumers.sdp_configuration_db.SDPConfigurationDB(pb_id, kind, flow_names, **config_kwargs)[source]

Consumer to connect to the SDP configuration database to update the flow states based on the received events.

process(event)[source]

Processes the event dictionary and updates flow states in SDP Config DB.