lst_auto_rta.Auto_RTA.assign_worker_to_data_connection¶

lst_auto_rta.Auto_RTA.assign_worker_to_data_connection(slurm_nodes: Dict[str, List[str]], tel_ids_to_data_servers: Dict[Annotated[int, Gt(gt=0)], List[DataStreamConnectionConfiguration]]) → List[ConnectionJobInfo][source]¶

Assign a worker node from slurm_nodes to each data server connection in tel_ids_to_data_servers

Parameters:

slurm_nodes (Dict[str, List[str]]) – Mapping from slurm reservation to slurm nodes, see AutoRTAConfiguration.slurm_nodes field.
tel_ids_to_data_servers (Dict[Annotated[int, Gt(0)], List[DataStreamConnectionConfiguration]]) – Mapping from telescope ID to data servers connections, see AutoRTAConfiguration.tel_ids_to_data_servers

Returns:

Map from (tel_id, hostname, port) to (slurm_reservation, slurm_nodename)

Return type:

Dict[Tuple[int, str, str], Tuple[str, str]]