kafka_dae_control.run_start_nexus_structure

Tools for generating the nexus structure field of a pl72 run start message.

Members

generate_nexus_structure

Generate the nexus structure for a run start using the data class.
kafka_dae_control.run_start_nexus_structure.generate_nexus_structure(config: ControlConfig, data: Data) → str[source]

Generate the nexus structure for a run start using the data class.

Parameters:

  • config – The program’s configuration

  • data – The data class containing the state of the program

Returns: a JSON-formatted string containing the nexus structure