ska_tmc_dishleafnode.manager

Submodules

component_manager

This module provides an implementation of the Dish Leaf Node ComponentManager.

class ska_tmc_dishleafnode.manager.component_manager.DishLNComponentManager(*args: Any, **kwargs: Any)

Bases: TmcLeafNodeComponentManager

A component manager for The Dish Leaf Node component.

abort(task_callback: ska_tango_base.base.TaskCallbackType) → Tuple

Abort the Dish.

Returns:

a result code and message

property actual_pointing: list

Returns the actualPointing of the dish device.

apply_pointing_model(argin: str, task_callback: ska_tango_base.base.TaskCallbackType) → Tuple[ska_tango_base.executor.TaskStatus, str]

Submits the ApplyPointingModel command for execution

Parameters:

argin – String giving TelModel URI.

Type:

str

Task_callback:

Callback function to handle task status.

Type:

TaskCallbackType

Returns:

A tuple containing TaskStatus and a message string.

Return type:

Tuple

check_device_responsive() → None

Checks if dish master device is responsive.

clear_configure_command_events_flags()

Method to reset the command result dictionaries, events and flags utilized in Configure command

clear_track_table_errors()

This method clears the variables that include track table errors

property command_in_progress: str

Method to get value of current command in progress

return: command in progress variable data rtype: str

configure(argin: str, task_callback: ska_tango_base.base.TaskCallbackType) → tuple

Submit the Configure command in queue.

Returns:

a result code and message

Return type:

Tuple

property configure_track_lrcr

Configure track lrcr

configureband(argin: str, task_callback: ska_tango_base.base.TaskCallbackType) → Tuple[ska_tango_base.executor.TaskStatus, str]

Submits the ConfigureBand command for execution.

Parameters:

• argin – String containing receiver band.

• task_callback – Callback function to handle task status.

Type:

str

Type:

TaskCallbackType

Returns:

A tuple containing TaskStatus and a message string.

Return type:

Tuple

convert_timestamp(timestamp_tai_ska_epoch: float) → str | None

Converts the timestamp in TAI format to UTC timestamp with format -> %Y-%m-%d %H:%M:%S The value 1999-12-31T23:59:28Z is the SKA_EPOCH

Parameters:

timestamp_tai_ska_epoch (float) – Input timestamp with time in TAI format with SKA epoch

Returns:

Timestamp in string with format “%Y-%m-%d %H:%M:%S”.

Return type:

string

create_converter_obj_and_antenna_obj()

Create AzElConverter Object and antenna object

property current_track_table_error

Returns the trackTableError of the dish leaf node.

property dishConfiguredBand: str

Returns the dishConfiguredBand of dish device

property dishMode: ska_tmc_common.DishMode

Returns the dishMode of dish master device

download_iers_data() → None

Downloads and initialises the IERS file. Incase of error with main link, tries downloading using Mirror link.

Returns:

None

Return type:

None

download_iers_data_from_a_different_source() → None

Downloads and initialises the IERS file from the mirror or local links.

Returns:

None

Return type:

None

endscan(task_callback: ska_tango_base.base.TaskCallbackType) → Tuple[ska_tango_base.executor.TaskStatus, str]

Submits the EndScan command for execution.

Parameters:

task_callback – Callback function to handle task status.

Type:

TaskCallbackType

Return type:

Tuple

get_abort_result_code() → ska_tango_base.commands.ResultCode

Return the result of the Abort command execution

Returns:

ResultCode from the set_abort_result

Return type:

ResultCode

get_abort_result_dict() → dict

Return the dictinary containing Abort command execution status

Returns:

abort_result dictionary

Return type:

dict

get_attribute_dict() → dict

This method will return dictionary of attributes which will be subscribed by TMC Dish Leaf Node. It will contain mapping of attribute with function which will process event data in TMC :return: Dictionary of attributes to be handled by the EventReceiver.

get_configure_band_result_code()

Return the result of the ConfigureBand command execution

Returns:

ResultCode from dictionary configure_band_result

Return type:

ResultCode

get_configure_band_result_dict()

Return the dictionary containing ConfigureBand command execution status

Returns:

configure_band_result dictionary

Return type:

dict

get_device() → ska_tmc_common.DishDeviceInfo

Return the device info of the monitoring loop with name dev_name

Returns:

a device info

Return type:

DishDeviceInfo

get_dish_state() → Tuple[ska_tmc_common.DishMode, ska_tmc_common.PointingState, ska_tmc_common.Band, ska_tango_base.commands.ResultCode, ska_tango_base.commands.ResultCode, ska_tango_base.commands.ResultCode]

Returns the current state of the dish including its mode, pointing state, band and the result code of the specified commands.

Returns:

• DishMode: The current operational mode of the dish.

• PointingState: The current pointing state of the dish.

• Band: The dish configured band

• ResultCode: ConfigureBand command result code

• ResultCode: SetOperateMode command result code

• ResultCode: Track command result code

Return type:

A tuple containing

get_end_scan_result_code()

Return the result of the EndScan command execution

Returns:

ResultCode from end_scan_result

Return type:

ResultCode

get_scan_result_code()

Return the result of the Scan command execution

Returns:

ResultCode from scan_result

Return type:

ResultCode

get_set_operate_mode_result_code()

Return the result of the SetOperateMode command execution

Returns:

ResultCode from the set_operate_mode_result

Return type:

ResultCode

get_set_operate_mode_result_dict()

Return the dictinary containing SetOperateMode command execution status

Returns:

set_operate_mode_result dictionary

Return type:

dict

get_track_load_static_off_result_code()

Return the result of the trackLoadStaticOff command execution

Returns:

track_load_static_off_result

Return type:

dict

get_track_load_static_off_result_dict()

Return the dictionary containing TrackLoadStaticOff command execution status

Returns:

track_load_static_off_result dictionary

Return type:

dict

get_track_result_code()

Return the result of the Track command execution

Returns:

ResultCode from the track_result

Return type:

ResultCode

get_track_result_dict()

Return the dictionary containing Track command execution status

Returns:

track_result dictionary

Return type:

dict

get_track_stop_result_code()

Return the result of the TrackStop command execution

Returns:

ResultCode from track_stop_result

Return type:

ResultCode

is_ApplyPointingModel_allowed() → bool

Checks if the command ApplyPointingModel is allowed.

Returns:

True if the command ‘ApplyPointingModel’ is allowed, False otherwise.

Return type:

boolean

is_abort_allowed() → bool

Checks whether this command is allowed It checks that the device is in the right state to execute this command and that all the component needed for the operation are not unresponsive

Returns:

True if this command is allowed

Return type:

boolean

is_abort_completed() → bool

Waits for expected state with or without transitional state. On expected state occurrence, it sets ResultCode to OK and stops the tracker thread.

Returns:

boolean value indicating if the state change occurred or not

is_command_allowed_callable(command_name: str)

Parameters:

command_name (str) – Name for the command for which the is_allowed check need to be applied.

is_configure_allowed() → bool

Checks if the given command is allowed in current operational state.

Returns:

True if the command is allowed in the current operational state, False otherwise.

Return type:

boolean

is_configure_completed() → bool

Waits for expected state with or without transitional state. On expected state occurrence, it sets ResultCode to OK and stops the tracker thread.

Returns:

boolean value indicating if the state change occurred or not

is_configureband_allowed() → bool

Checks if the given command is allowed in current operational state.

Returns:

True if the command is allowed in the current operational state, False otherwise.

Return type:

boolean

is_endscan_allowed() → bool

Checks if the given command is allowed in current operational state.

Returns:

True if this command is allowed to be run in current dish mode, raises CommandNotAllowed in case is is not allowed and DeviceUnresponsive in case Device is not responsive.

Return type:

Union[bool, CommandNotAllowed, DeviceUnresponsive]

is_off_allowed() → bool

Checks if the given command is allowed in current operational state.

Returns:

True if the command is allowed in the current operational state, False otherwise.

Return type:

boolean

is_scan_allowed() → bool

Checks if the given command is allowed in current operational state.

Returns:

True if this command is allowed to be run in current dish mode, raises CommandNotAllowed in case is is not allowed and DeviceUnresponsive in case Device is not responsive.

Return type:

Union[bool, CommandNotAllowed, DeviceUnresponsive]

is_set_kvalue_allowed() → bool

Checks whether this command is allowed It checks that the device is responsive before invoking command.

Returns:

True if this command is allowed

Return type:

boolean

is_setoperatemode_allowed() → bool

Checks if the given command is allowed in current operational state.

Returns:

True if the command is allowed in the current operational state, False otherwise.

Return type:

boolean

is_setstandbyfpmode_allowed() → bool

Checks if the given command is allowed in current operational state.

Return type:

boolean

is_setstandbylpmode_allowed() → bool

Checks if the given command is allowed in current operational state.

Return type:

boolean

is_setstowmode_allowed() → bool

Checks if the given command is allowed in current operational state.

Returns:

True if the command is allowed in the current operational state, False otherwise.

Return type:

boolean

is_track_allowed() → bool

Checks if the given command is allowed in current operational state.

Returns:

True if the command is allowed in the current operational state, False otherwise.

Return type:

boolean

is_track_and_trackstop_command_allowed()

checks if track command is allowed

is_trackloadstaticoff_allowed() → bool

Checks if the command TrackLoadStaticOff is allowed.

Returns:

True if the command ‘TrackLoadStaticOff’ is allowed, False otherwise.

Return type:

boolean

is_trackstop_allowed() → bool

Checks if the given command is allowed in current operational state.

Returns:

True if the command is allowed in the current operational state, False otherwise.

Return type:

boolean

property kValue: int

Returns the k-value

property kValueValidationResult: int

Returns the k-value validation result

Returns:

The k-value validation result

Return type:

int

property last_pointing_data

Property for last pointing data

off(task_callback: ska_tango_base.base.TaskCallbackType) → Tuple[ska_tango_base.executor.TaskStatus, str]

Submits the Off command for execution.

Return type:

Tuple

perform_reverse_transform(value_list)

Performs the reverse transform and publishes it on the actualPointing attribute.

Parameters:

value_list ((List[float])) – A list containing timestamp in milliseconds,azimuth, and elevation.

Returns:

None

Return type:

None

property pointingState: ska_tmc_common.PointingState

Returns the pointingState of dish master device

property primary_configuration: dict

Return primary configuration

process_actual_pointing() → None

Process the achieved pointing data to calculate actual pointing.

Returns:

None

Return type:

None

process_pointing_calibration(event_data: tango.EventData) → None

Method to process pointing offsets received from SDP queue connector device

process_sqpqc_attribute_fqdn(sdpqc_fqdn: str) → None

Method to subscribe to SDP queue connector attribute. :type attribute_name: str :return: None :rtype: None

property queue_connector_device_info: ska_tmc_common.SdpQueueConnectorDeviceInfo

Get the queue connector device object

reset_command_result_values()

Method to reset the command result dictionaries for the commands ConfigureBand, SetOperateMode, Track and TrackLoadStaticOff

scan(argin: str, task_callback: ska_tango_base.base.TaskCallbackType) → Tuple[ska_tango_base.executor.TaskStatus, str]

Submits the Scan command for execution.

Parameters:

• argin – JSON string containing offsets in the form of param.

• task_callback – Callback function to handle task status.

Type:

str

Type:

TaskCallbackType

Returns:

A tuple containing TaskStatus and a message string.

Return type:

Tuple

set_configure_band_result_dict(result_code=None, message=None, exception=None, status=None)

Set the dictionary containing ConfigureBand command execution status

Parameters:

result_code (ResultCode) – ResultCode to be set in configure_band_result

Param:

message to be set in configure_band_result

Type:

str

Param:

exception to be set in configure_band_result

Type:

str

Param:

status to be set in configure_band_result

Type:

str

set_dish_adapter(dish_adapter: ska_tmc_common.adapters.DishAdapter) → None

Sets dish adapter, used to write programTrackTable on the dish.

set_dish_id(dish_master_fqdn: str) → None

Find out dish number from MidDishControl property e.g. mid-dish/dish-manager/SKA001 Here, SKA001 is the dish number.

set_dishln_pointing_device_adapter(dishln_pointing_device_adapter: ska_tmc_common.adapters.DishlnPointingDeviceAdapter) → None

Sets dishln pointing device adapter, used to write programTrackTable on the dish.

set_track_load_static_off_result_dict(result_code=None, message=None, exception=None, status=None)

Set the dictionary containing TrackLoadStaticOff command execution status

Parameters:

result_code (ResultCode) – ResultCode to be set in track_load_static_off_result

Param:

message to be set in track_load_static_off_result

Type:

str

Param:

exception to be set in track_load_static_off_result

Type:

str

Param:

status to be set in track_load_static_off_result

Type:

str

set_track_result_dict(result_code=None, message=None, exception=None, status=None)

Set the dictionary containing Track command execution status

Parameters:

result_code (ResultCode) – ResultCode to be set in track_result

Param:

message to be set in track_result

Type:

str

Param:

exception to be set in track_result

Type:

str

Param:

status to be set in track_result

Type:

str

setoperatemode(task_callback: ska_tango_base.base.TaskCallbackType) → Tuple[ska_tango_base.executor.TaskStatus, str]

Submits the SetOperateMode command for execution.

Parameters:

task_callback – Callback function to handle task status.

Type:

TaskCallbackType

Returns:

A tuple containing TaskStatus and a message string.

Return type:

Tuple

setstandbyfpmode(task_callback: ska_tango_base.base.TaskCallbackType) → Tuple[ska_tango_base.executor.TaskStatus, str]

Initializes the attributes and properties of the DishLeafNode.

Returns:

A tuple containing a return code and a string message indicating status. The message is for information purpose only.

setstandbylpmode(task_callback: ska_tango_base.base.TaskCallbackType) → Tuple[ska_tango_base.executor.TaskStatus, str]

Submits the SetStandbyLPMode command for execution.

Parameters:

task_callback – Callback function to handle task status.

Type:

TaskCallbackType

Returns:

A tuple containing TaskStatus and a message string.

Return type:

Tuple

setstowmode(task_callback: ska_tango_base.base.TaskCallbackType) → Tuple[ska_tango_base.executor.TaskStatus, str]

Submits the SetStowMode command for execution.

Parameters:

task_callback – Callback function to handle task status.

Type:

TaskCallbackType

Returns:

A tuple containing TaskStatus and a message string.

Return type:

Tuple

start_event_processing_threads() → None

Start all the event processing threads.

stop_event_processing_threads() → None

Stop all event-processing threads: 1) Signal them to exit their loops. 2) Wait (join) until each thread has terminated. 3) Clean up queues and thread list.

stop_event_receiver() → None

Stops the Event Receiver

Returns:

None

stop_executors_and_cleanup_memory() → None

Method to clean up the code, stop running threads/sub-processes

Returns:

None

Return type:

None

track(argin: str, task_callback: ska_tango_base.base.TaskCallbackType) → Tuple[ska_tango_base.executor.TaskStatus, str]

Submits the Track command for execution.

Parameters:

• argin – JSON string containing offsets in the form of param.

• task_callback – Callback function to handle task status.

Type:

str

Type:

TaskCallbackType

Returns:

A tuple containing TaskStatus and a message string.

Return type:

Tuple

property trackTableLoadMode: ska_tmc_common.TrackTableLoadMode

Returns dish’s trackTableLoadMode attribute value.

Returns:

TrackTableLoadMode

Return type:

enum

track_load_static_off(argin: str, task_callback: ska_tango_base.base.TaskCallbackType) → Tuple[ska_tango_base.executor.TaskStatus, str]

Submits the TrackLoadStaticOff command for execution

Parameters:

argin – JSON string containing offsets in the form of param.

Type:

str

Task_callback:

Callback function to handle task status.

Type:

TaskCallbackType

Returns:

A tuple containing TaskStatus and a message string.

Return type:

Tuple

trackstop(task_callback: ska_tango_base.base.TaskCallbackType) → Tuple[ska_tango_base.executor.TaskStatus, str]

Submits the TrackStop command for execution.

Parameters:

task_callback – Callback function to handle task status.

Type:

TaskCallbackType

Returns:

A tuple containing TaskStatus and a message string.

Return type:

Tuple

update_command_result(value) → None

Method to update task callback based on long running command result

event data.

Parameters:

value – longRunningCommandResult attribute event data

Type:

(Tuple[List[str], List[str]])

update_configured_band_event(event: tango.EventData) → None

Updates configured band event in respective queue :param event: It is the Tango Event Data object which contains the event data, dishMode Event in this case. :type event: tango.EventData :return: None :rtype: None

update_device_configured_band(configured_band: ska_tmc_common.Band) → None

Update the configured band of the given dish and call the relative callbacks if available.

Parameters:

configured_band (Band) – Configured band of the dish device

update_device_dish_mode(dish_mode: ska_tmc_common.DishMode) → None

Update the dish mode of the given dish and call the relative callbacks if available.

Parameters:

dishMode (DishMode) – Dish mode of the device

update_device_health_state(health_state: ska_tango_base.control_model.HealthState) → None

Update a monitored device health state

Parameters:

health_state (HealthState) – health state of the device

update_device_pointing_state(pointingState: ska_tmc_common.PointingState) → None

Update the pointing state of the given dish and call the relative callbacks if available.

Parameters:

pointingState (PointingState) – Pointing state of the dish device

Returns:

None

Return type:

None

update_dish_mode_event(event: tango.EventData) → None

Updates dish mode event in respective queue :param event: It is the Tango Event Data object which contains the event data, dishMode Event in this case. :type event: tango.EventData :return: None :rtype: None

update_dish_pointing_model_param(dish_param: str, band_name: str) → None

Update the dish pointing model parameter for the specified band and invoke the relevant callbacks if available.

Parameters:

• dish_param (str) – New value for the dish pointing model parameter.

• band_name (str) – Name of the band to update.

update_dish_pointing_model_params(event: tango.EventData) → None

Updates dish pointing model param event in respective queue :param event: It is the Tango Event Data object which contains the event data, dishMode Event in this case. :type event: tango.EventData :return: None :rtype: None

update_exception_for_unresponsiveness(device_info: ska_tmc_common.DeviceInfo, exception: str) → None

Set a device to failed and call the relative callback if available

Parameters:

• device_info (DeviceInfo) – a device info

• exception – an exception

Type:

Exception

Return type:

None

update_kvalue_validation_result() → None

This method informs the k-value validation result to central node after DLN start/restart.

Returns:

None

Return type:

None

update_pointing_program_track_table_event(event: tango.EventData) → None

Updates pointing program track table event in respective queue :param event: It is the Tango Event Data object which contains the event data, dishMode Event in this case. :type event: tango.EventData :return: None :rtype: None

update_pointing_state_event(event: tango.EventData) → None

Updates pointing state event in respective queue :param event: It is the Tango Event Data object which contains the event data, dishMode Event in this case. :type event: tango.EventData :return: None :rtype: None

update_program_track_table(program_track_table_event_data: tango.EventData) → None

This method writes the programTrackTable attribute on dish master device.

Parameters:

program_track_table_event_data (list) – It a list of TAI time, Az and El for expected number of TAI times (TrackTableEntries).

Returns:

None

Return type:

None

update_program_track_table_error(event: tango.EventData) → None

Updates program track table error :param event: It is the Tango Event Data object which contains the event data, dishMode Event in this case. :type event: tango.EventData :return: None :rtype: None

update_program_track_table_error_event(event: tango.EventData) → None

Updates program track table error event in respective queue :param event: It is the Tango Event Data object which contains the event data, dishMode Event in this case. :type event: tango.EventData :return: None :rtype: None

update_responsiveness_info(device_name: str) → None

Update a device with the correct availability information.

Parameters:

dev_name (str) – name of the device

update_set_operate_mode_result_dict(result_code=None, message=None, exception=None, status=None)

Set the dictionary containing SetOperateMode command execution status

Parameters:

result_code (ResultCode) – ResultCode to be set in set_operate_mode_result

Param:

message to be set in set_operate_mode_result

Type:

str

Param:

exception to be set in set_operate_mode_result

Type:

str

Param:

status to be set in set_operate_mode_result

Type:

str

update_source_offset_callback(source_offset: list) → None

Method to update the sourceOffset attribute

validate_float_list(lst: list, number_of_values: int) → bool

Method to check the list in valid format

Type:

number_of_values: int

Returns:

bool

Return type:

bool

ska_tmc_dishleafnode.manager.program_track_table_calculator module

Module for programTrackTable calculator.

class ska_tmc_dishleafnode.manager.program_track_table_calculator.ProgramTrackTableCalculator(component_manager, logger: Logger)

Bases: object

Class for programTrackTableCalculator.

azel_converter: AzElConverter

calculate_program_track_table(target_data: Union[str, List[str]], azel_converter: AzElConverter) → list

This method calculates programTrackTable.

Parameters:

target_data (Union[str, List[str]]) – The name or RaDec for the target

Returns:

list in the form of [TAI1, Az1, El1, TAI2, Az2, El2,,,,,,TAIn, Azn, Eln].

Return type:

list

calculate_time_stamp_list() → tuple

This methods calculates an list of requested timestamps (TrackTableEntries) with a requested time difference (PointingCalculationPeriod) and corresponding list of time in TAI format.

Returns:

Tuple with list of timestamps (UTC) in string format and timestamp in TAI format.

Return type:

tuple

convert_utc_to_tai(utc_time: float) → float

This method converts utc time to tai format time. :param: utc_time: time in utc (seconds) :type utc_time: float :returns: Time in TAI format (seconds) :rtype: float

declination: str = ''

elevation_limit: bool

fit_azimuth_in_observable_range(calculated_azimuth: float) → float

This method fits the calculated azimuth to the dish’s observable azimuth range. :param: calculated_azimuth: Azimuth in degrees :type calculated_azimuth: float :returns: Azimuth in degrees :rtype: float

point(timestamp: str) → list

This method converts Target RaDec coordinates to the AzEl coordinates. It is called continuously from Configure command (in a thread) at interval of 50ms till the StopTrack command is invoked.

Parameters:

timestamp (str) – utc timestamp

Returns:

Azimuth and Elevation coordinates (Az, El) of source.

Return type:

list

right_ascension: str = ''

target_name: str = ''

weather_data: dict

ska_tmc_dishleafnode.manager.event_receiver module

Event Receiver for Dish Leaf Node

class ska_tmc_dishleafnode.manager.event_receiver.DishLNEventReceiver(*args: Any, **kwargs: Any)

Bases: EventReceiver

The DishLNEventReceiver class has the responsibility to receive events from the dish master managed by the Dish Leaf Node.

The ComponentManager uses to handle events methods for the attribute of interest. For each of them a callback is defined.

handle_achieved_pointing_event(event_flag: tango.EventData) → None

Method to handle and update the latest value of achievedPointing attribute.

Parameters:

event_flag (tango.EventType.CHANGE_EVENT) – To flag the change in event for achievedPointing.

Returns:

None

Return type:

NoneType

handle_configured_band_event(event_flag: tango.EventData) → None

Method to handle and update the latest value of configuredBand attribute.

Parameters:

event_flag (tango.EventType.CHANGE_EVENT) – To flag the change in event for configuredBand.

Returns:

None

Return type:

NoneType

handle_dish_mode_event(event_flag: tango.EventData) → None

Method to handle and update the latest value of dishMode attribute.

Parameters:

event_flag (tango.EventType.CHANGE_EVENT) – To flag the change in event for dishMode.

Returns:

None

Return type:

NoneType

handle_dishlnpd_healthState_event(event_flag: tango.EventData) → None

Method to handle and update the latest value of pointing device healthState. If this value/event is unavailable, DishLeaf node healthState is shown as DEGRADED.

Parameters:

event_flag (tango.EventType.CHANGE_EVENT) – To flag the change in event for programTrackTable.

Returns:

None

Return type:

NoneType

handle_pointing_model_params(event_flag: tango.EventData)

Method to handle and update the latest value of dish_pointing_model params.

Parameters:

event_flag (tango.EventType.CHANGE_EVENT) – To flag the change in event for Dishglobalpoing params.

Returns:

None

Return type:

NoneType

handle_pointing_program_track_table_event(event_flag: tango.EventData) → None

Method to handle and update the latest value of pointingProgramTrackTable attribute.

Parameters:

event_flag (tango.EventType.CHANGE_EVENT) – To flag the change in event for programTrackTable.

Returns:

None

Return type:

NoneType

handle_pointing_state_event(event_flag: tango.EventData) → None

Method to handle and update the latest value of pointingState attribute.

Parameters:

event_flag (tango.EventType.CHANGE_EVENT) – To flag the change in event for pointingState.

Returns:

None

Return type:

NoneType

handle_program_track_table_error_event(event_flag: tango.EventData) → None

Method to handle and update the latest value of program track table error attribute.

Parameters:

event_flag (tango.EventType.CHANGE_EVENT) – To flag the change in event for programTrackTableError.

Returns:

None

Return type:

NoneType

run() → None

subscribe_dish_master_events(dev_info: ska_tmc_common.DishDeviceInfo, attribute_dictionary=None) → None

Subscribe to Dish Master

subscribe_dishlnpd_events(dlnPointingDev_name: str, attribute_dictionary=None) → None

Subscribe to DishLeaf Node Pointing Device events.

Parameters:

• self (DishLNEventReceiver) – The DishLNEventReceiver instance.

• dlnPointingDev_name (str) – The name of the DishLeaf Node Pointing Device to subscribe to.

• attribute_dictionary (Optional[dict]) – Dictionary containing attribute configurations for the subscription. Defaults to None.

Return type:

None

Notes

This method establishes event subscriptions for a DishLeaf Node Pointing Device using the provided device name and optional attribute configurations.

subscribe_sdpqc_attribute(dev_info: ska_tmc_common.SdpQueueConnectorDeviceInfo, attribute_name: str) → None

Subscribe to the given SDP queue connector attribute

unsubscribe_sdpqc_attribute(dev_info: ska_tmc_common.SdpQueueConnectorDeviceInfo) → None

Subscribe to the given SDP queue connector attribute

ska_tmc_dishleafnode.manager.dish_kvalue_validation_manager module

Class for managing dish kvalue validation during initialization/restart of device

class ska_tmc_dishleafnode.manager.dish_kvalue_validation_manager.DishkValueValidationManager(component_manager, logger)

Bases: object

Class for dish kValue validation during dish leaf node initialization/restart

get_dish_ln_memorized_kvalue() → int

Return memorized kvalue dish leaf node :return: int

get_dish_manager_kvalue() → int

Get kValue attribute value of dish manager :return: int

is_dish_manager_ready() → bool

Wait and check if dish manager is ready :return: bool

validate_dish_kvalue() → None

Validate kvalue of dish leaf node and dish manager :return: None