ska_tmc_subarraynode package

Subpackages

• ska_tmc_subarraynode.commands package
• Submodules
  • subarray_node_command
    • SubarrayNodeCommand
      • SubarrayNodeCommand.adapter_error_message_result()
      • SubarrayNodeCommand.clear_device_events()
      • SubarrayNodeCommand.do()
      • SubarrayNodeCommand.do_low()
      • SubarrayNodeCommand.do_mid()
      • SubarrayNodeCommand.get_adapter_by_device_name()
      • SubarrayNodeCommand.get_dish_adapter_by_device_name()
      • SubarrayNodeCommand.init_adapters()
      • SubarrayNodeCommand.init_adapters_low()
      • SubarrayNodeCommand.init_adapters_mid()
      • SubarrayNodeCommand.reject_command()
      • SubarrayNodeCommand.task_callback_default()
      • SubarrayNodeCommand.update_command_in_progress_id()
      • SubarrayNodeCommand.update_event_data_storage()
      • SubarrayNodeCommand.update_task_status()
  • assign_resources_command
    • AssignResources
      • AssignResources.assign_csp_resources()
      • AssignResources.assign_low_csp_resources()
      • AssignResources.assign_sdp_resources()
      • AssignResources.clear_resources()
      • AssignResources.do_low()
      • AssignResources.do_mid()
      • AssignResources.get_csp_resources_low()
      • AssignResources.set_up_dish_data()
      • AssignResources.update_task_status()
      • AssignResources.validate_low_json()
  • configure_command
    • Configure
      • Configure.check_only_dish_config()
      • Configure.configure_adapters()
      • Configure.configure_mapping_scan_dishes()
      • Configure.do_low()
      • Configure.do_mid()
      • Configure.get_and_verify_k_values()
      • Configure.update_task_status()
  • end_command
    • End
      • End.do_low()
      • End.do_mid()
      • End.end_csp()
      • End.end_mccs()
      • End.end_sdp()
      • End.stop_dish_tracking()
      • End.update_task_status()
  • end_scan_command
    • EndScan
      • EndScan.do_low()
      • EndScan.do_mid()
      • EndScan.end_scan_low()
      • EndScan.end_scan_mccs()
      • EndScan.end_scan_mid()
      • EndScan.endscan_csp()
      • EndScan.endscan_dishes()
      • EndScan.endscan_sdp()
      • EndScan.update_task_status()
  • release_all_resources_command
    • ReleaseAllResources
      • ReleaseAllResources.clean_up_low_resources()
      • ReleaseAllResources.clean_up_mid_resources()
      • ReleaseAllResources.do_low()
      • ReleaseAllResources.do_mid()
      • ReleaseAllResources.release_csp_resources()
      • ReleaseAllResources.release_sdp_resources()
      • ReleaseAllResources.update_task_status()
  • restart_command
    • Restart
      • Restart.clean_up_configuration()
      • Restart.clean_up_dishes()
      • Restart.do_low()
      • Restart.do_mid()
      • Restart.restart_csp()
      • Restart.restart_dishes()
      • Restart.restart_mccs()
      • Restart.restart_sdp()
      • Restart.update_task_status()
  • scan_command
    • Scan
      • Scan.do_low()
      • Scan.do_mid()
      • Scan.scan_csp()
      • Scan.scan_csp_low()
      • Scan.scan_dishes()
      • Scan.scan_mccs()
      • Scan.scan_sdp()
      • Scan.send_scan_on_leaf_nodes()
      • Scan.start_scan_timer()
      • Scan.submit_endscan_command()
      • Scan.update_mccs_json()
      • Scan.update_task_status()
  • off_command
    • Off
      • Off.do_low()
      • Off.do_mid()
      • Off.get_csp_subarray_obstate()
      • Off.get_sdp_subarray_obstate()
      • Off.get_subarray_obstate()
      • Off.subarray_off()
      • Off.update_task_status()
  • on_command
    • On
      • On.do_low()
      • On.do_mid()
      • On.on_leaf_nodes()
  • set_admin_mode_command
    • SetAdminMode
      • SetAdminMode.do_low()
      • SetAdminMode.invoke_setadminmode()
      • SetAdminMode.set_admin_mode_csp()
      • SetAdminMode.set_admin_mode_mccs()
      • SetAdminMode.set_admin_mode_sdp()
  • Module contents
• ska_tmc_subarraynode.manager package
• Submodules
  • aggregators
    • HealthStateAggregatorLow
      • HealthStateAggregatorLow.aggregate()
    • HealthStateAggregatorMid
      • HealthStateAggregatorMid.aggregate()
    • ObsStateAggregator
      • ObsStateAggregator.aggregate()
    • SubarrayAvailabilityAggregatorLow
      • SubarrayAvailabilityAggregatorLow.aggregate()
    • SubarrayAvailabilityAggregatorMid
      • SubarrayAvailabilityAggregatorMid.aggregate()
  • event_receiver
    • SubarrayNodeEventReceiver
      • SubarrayNodeEventReceiver.admin_mode_event_callback()
      • SubarrayNodeEventReceiver.check_event_error()
      • SubarrayNodeEventReceiver.device_attribute_event_ids
      • SubarrayNodeEventReceiver.handle_assigned_resources_event()
      • SubarrayNodeEventReceiver.handle_dish_mode_event()
      • SubarrayNodeEventReceiver.handle_health_state_event()
      • SubarrayNodeEventReceiver.handle_lrcr_event()
      • SubarrayNodeEventReceiver.handle_pointing_state_event()
      • SubarrayNodeEventReceiver.handle_receive_addresses_event()
      • SubarrayNodeEventReceiver.handle_state_event()
      • SubarrayNodeEventReceiver.handle_subsystem_availability_event()
      • SubarrayNodeEventReceiver.log_event_data()
      • SubarrayNodeEventReceiver.log_event_exit()
      • SubarrayNodeEventReceiver.obs_state_event_callback()
      • SubarrayNodeEventReceiver.set_device_attribute_event_ids()
      • SubarrayNodeEventReceiver.subscribe_events()
      • SubarrayNodeEventReceiver.subscribe_to_event()
      • SubarrayNodeEventReceiver.unsubscribe_dish_events()
      • SubarrayNodeEventReceiver.unsubscribe_dish_leaf_events()
      • SubarrayNodeEventReceiver.unsubscribe_to_events_with_prefix()
  • subarray_node_component_manager
    • SubarrayNodeComponentManager
      • SubarrayNodeComponentManager.abort()
      • SubarrayNodeComponentManager.add_device_to_lp()
      • SubarrayNodeComponentManager.add_multiple_devices()
      • SubarrayNodeComponentManager.add_similar_low_mid_device()
      • SubarrayNodeComponentManager.aggregate_process_monitor()
      • SubarrayNodeComponentManager.assign()
      • SubarrayNodeComponentManager.assigned_resources
      • SubarrayNodeComponentManager.check_command_not_allowed_exception()
      • SubarrayNodeComponentManager.check_event_error()
      • SubarrayNodeComponentManager.check_for_incremental_assign_and_revise_obsstate()
      • SubarrayNodeComponentManager.check_if_sdp_sln_is_available()
      • SubarrayNodeComponentManager.check_subarray_device_availability()
      • SubarrayNodeComponentManager.check_successive_configure_revise_obsstate()
      • SubarrayNodeComponentManager.checked_devices
      • SubarrayNodeComponentManager.clear_assigned_resources()
      • SubarrayNodeComponentManager.command_allowed_callable()
      • SubarrayNodeComponentManager.command_in_progress
      • SubarrayNodeComponentManager.component_state_changed_callback_and_logging()
      • SubarrayNodeComponentManager.configure()
      • SubarrayNodeComponentManager.devices
      • SubarrayNodeComponentManager.end()
      • SubarrayNodeComponentManager.end_scan()
      • SubarrayNodeComponentManager.end_singular_scan()
      • SubarrayNodeComponentManager.generate_command_result()
      • SubarrayNodeComponentManager.get_assigned_resources()
      • SubarrayNodeComponentManager.get_csp_subarray_dev_name()
      • SubarrayNodeComponentManager.get_device()
      • SubarrayNodeComponentManager.get_mccs_subarray_dev_name()
      • SubarrayNodeComponentManager.get_sb_id()
      • SubarrayNodeComponentManager.get_scan_duration()
      • SubarrayNodeComponentManager.get_scan_id()
      • SubarrayNodeComponentManager.get_sdp_subarray_dev_name()
      • SubarrayNodeComponentManager.get_subarray_availability()
      • SubarrayNodeComponentManager.get_subarray_healthstate()
      • SubarrayNodeComponentManager.get_subarray_id()
      • SubarrayNodeComponentManager.get_subarray_obsstate()
      • SubarrayNodeComponentManager.get_tmc_csp_sln_device_name()
      • SubarrayNodeComponentManager.get_tmc_mccs_sln_device_name()
      • SubarrayNodeComponentManager.get_tmc_sdp_sln_device_name()
      • SubarrayNodeComponentManager.input_parameter
      • SubarrayNodeComponentManager.is_command_allowed()
      • SubarrayNodeComponentManager.is_operation_aborted
      • SubarrayNodeComponentManager.is_partial_configuration
      • SubarrayNodeComponentManager.is_scan_completed()
      • SubarrayNodeComponentManager.is_scan_timer_running()
      • SubarrayNodeComponentManager.log_state()
      • SubarrayNodeComponentManager.off()
      • SubarrayNodeComponentManager.on()
      • SubarrayNodeComponentManager.process_event()
      • SubarrayNodeComponentManager.release_all()
      • SubarrayNodeComponentManager.remove_devices_from_lp()
      • SubarrayNodeComponentManager.reset()
      • SubarrayNodeComponentManager.reset_sb_id()
      • SubarrayNodeComponentManager.reset_scan_duration()
      • SubarrayNodeComponentManager.reset_scan_id()
      • SubarrayNodeComponentManager.reset_subarray_id()
      • SubarrayNodeComponentManager.restart()
      • SubarrayNodeComponentManager.scan()
      • SubarrayNodeComponentManager.set_admin_mode()
      • SubarrayNodeComponentManager.set_assigned_resources()
      • SubarrayNodeComponentManager.set_pattern_scan_data()
      • SubarrayNodeComponentManager.set_sb_id()
      • SubarrayNodeComponentManager.set_scan_duration()
      • SubarrayNodeComponentManager.set_scan_id()
      • SubarrayNodeComponentManager.set_subarray_id()
      • SubarrayNodeComponentManager.stop()
      • SubarrayNodeComponentManager.stop_aggregation_process()
      • SubarrayNodeComponentManager.stop_all_process()
      • SubarrayNodeComponentManager.stop_event_receiver()
      • SubarrayNodeComponentManager.stop_liveliness_probe()
      • SubarrayNodeComponentManager.stop_scan_timer()
      • SubarrayNodeComponentManager.subarray_obsstate
      • SubarrayNodeComponentManager.unavailable_devices
      • SubarrayNodeComponentManager.unsubscribe_dish_events()
      • SubarrayNodeComponentManager.update_assigned_resources()
      • SubarrayNodeComponentManager.update_device_admin_mode()
      • SubarrayNodeComponentManager.update_device_dish_mode()
      • SubarrayNodeComponentManager.update_device_health_state()
      • SubarrayNodeComponentManager.update_device_obs_state()
      • SubarrayNodeComponentManager.update_device_pointing_state()
      • SubarrayNodeComponentManager.update_device_state()
      • SubarrayNodeComponentManager.update_event_failure()
      • SubarrayNodeComponentManager.update_exception_for_unresponsiveness()
      • SubarrayNodeComponentManager.update_input_parameter()
      • SubarrayNodeComponentManager.update_long_running_command_result()
      • SubarrayNodeComponentManager.update_receive_addresses()
      • SubarrayNodeComponentManager.update_responsiveness_info()
      • SubarrayNodeComponentManager.update_subarray_availability_status()
  • Module contents
    • AggregationProcessLow
    • AggregationProcessMid
    • EventDataManager
      • EventDataManager.clear_dish_data()
      • EventDataManager.clear_lrcr()
      • EventDataManager.compare_timevals()
      • EventDataManager.get_enum_name_from_value()
      • EventDataManager.update_aggragation_queue()
      • EventDataManager.update_event_data()
    • HealthStateAggregatorLow
      • HealthStateAggregatorLow.aggregate()
    • HealthStateAggregatorMid
      • HealthStateAggregatorMid.aggregate()
    • SubarrayAvailabilityAggregatorLow
      • SubarrayAvailabilityAggregatorLow.aggregate()
    • SubarrayAvailabilityAggregatorMid
      • SubarrayAvailabilityAggregatorMid.aggregate()
    • SubarrayNodeComponentManagerLow
      • SubarrayNodeComponentManagerLow.add_device_to_lp()
      • SubarrayNodeComponentManagerLow.check_successive_configure_revise_obsstate()
      • SubarrayNodeComponentManagerLow.configured_capabilities
      • SubarrayNodeComponentManagerLow.deconfigure()
      • SubarrayNodeComponentManagerLow.get_devices_availability_dict()
      • SubarrayNodeComponentManagerLow.obsreset()
      • SubarrayNodeComponentManagerLow.release()
      • SubarrayNodeComponentManagerLow.standby()
      • SubarrayNodeComponentManagerLow.start_communicating()
      • SubarrayNodeComponentManagerLow.stop_aggregation_process()
      • SubarrayNodeComponentManagerLow.stop_communicating()
      • SubarrayNodeComponentManagerLow.update_long_running_command_result()
    • SubarrayNodeComponentManagerMid
      • SubarrayNodeComponentManagerMid.add_device_to_lp()
      • SubarrayNodeComponentManagerMid.clear_assigned_resources()
      • SubarrayNodeComponentManagerMid.configured_capabilities
      • SubarrayNodeComponentManagerMid.deconfigure()
      • SubarrayNodeComponentManagerMid.get_devices_availability_dict()
      • SubarrayNodeComponentManagerMid.get_dish_dev_names()
      • SubarrayNodeComponentManagerMid.get_dish_leaf_node_prefix()
      • SubarrayNodeComponentManagerMid.get_keys_required_for_getting_sdpqc_fqdn()
      • SubarrayNodeComponentManagerMid.get_normal_scan_dish_device_names()
      • SubarrayNodeComponentManagerMid.get_tmc_dish_ln_device_names()
      • SubarrayNodeComponentManagerMid.get_trajectory_dish_device_names()
      • SubarrayNodeComponentManagerMid.invoke_pointing_calibration()
      • SubarrayNodeComponentManagerMid.kvalue_validation_failed
      • SubarrayNodeComponentManagerMid.obsreset()
      • SubarrayNodeComponentManagerMid.process_lrcrevent()
      • SubarrayNodeComponentManagerMid.release()
      • SubarrayNodeComponentManagerMid.remove_dish_devices()
      • SubarrayNodeComponentManagerMid.set_dish_device_names()
      • SubarrayNodeComponentManagerMid.set_keys_required_for_getting_sdpqc_fqdn()
      • SubarrayNodeComponentManagerMid.set_normal_scan_dish_device_names()
      • SubarrayNodeComponentManagerMid.set_pattern_scan_data()
      • SubarrayNodeComponentManagerMid.set_tmc_leaf_dish_device_names()
      • SubarrayNodeComponentManagerMid.set_trajectory_dish_device_names()
      • SubarrayNodeComponentManagerMid.standby()
      • SubarrayNodeComponentManagerMid.start_communicating()
      • SubarrayNodeComponentManagerMid.stop_aggregation_process()
      • SubarrayNodeComponentManagerMid.stop_communicating()
      • SubarrayNodeComponentManagerMid.update_long_running_command_result()
    • SubarrayNodeEventReceiver
      • SubarrayNodeEventReceiver.admin_mode_event_callback()
      • SubarrayNodeEventReceiver.check_event_error()
      • SubarrayNodeEventReceiver.device_attribute_event_ids
      • SubarrayNodeEventReceiver.handle_assigned_resources_event()
      • SubarrayNodeEventReceiver.handle_dish_mode_event()
      • SubarrayNodeEventReceiver.handle_health_state_event()
      • SubarrayNodeEventReceiver.handle_lrcr_event()
      • SubarrayNodeEventReceiver.handle_pointing_state_event()
      • SubarrayNodeEventReceiver.handle_receive_addresses_event()
      • SubarrayNodeEventReceiver.handle_state_event()
      • SubarrayNodeEventReceiver.handle_subsystem_availability_event()
      • SubarrayNodeEventReceiver.log_event_data()
      • SubarrayNodeEventReceiver.log_event_exit()
      • SubarrayNodeEventReceiver.obs_state_event_callback()
      • SubarrayNodeEventReceiver.set_device_attribute_event_ids()
      • SubarrayNodeEventReceiver.subscribe_events()
      • SubarrayNodeEventReceiver.subscribe_to_event()
      • SubarrayNodeEventReceiver.unsubscribe_dish_events()
      • SubarrayNodeEventReceiver.unsubscribe_dish_leaf_events()
      • SubarrayNodeEventReceiver.unsubscribe_to_events_with_prefix()
• ska_tmc_subarraynode.model package
• Submodules
  • component module
    • SubarrayComponent
      • SubarrayComponent.assigned_resources
      • SubarrayComponent.devices
      • SubarrayComponent.get_device()
      • SubarrayComponent.invoke_device_callback()
      • SubarrayComponent.remove_device()
      • SubarrayComponent.sb_id
      • SubarrayComponent.scan_duration
      • SubarrayComponent.scan_id
      • SubarrayComponent.set_obs_callbacks()
      • SubarrayComponent.set_op_callbacks()
      • SubarrayComponent.subarray_availability
      • SubarrayComponent.subarray_health_state
      • SubarrayComponent.subarray_id
      • SubarrayComponent.to_dict()
      • SubarrayComponent.update_device()
      • SubarrayComponent.update_device_exception()
  • enum module
    • PointingState
      • PointingState.NONE
      • PointingState.READY
      • PointingState.SCAN
      • PointingState.SLEW
      • PointingState.TRACK
      • PointingState.UNKNOWN
  • input module
    • InputParameter
      • InputParameter.csp_subarray_dev_name
      • InputParameter.sdp_subarray_dev_name
      • InputParameter.tmc_csp_sln_device_name
      • InputParameter.tmc_sdp_sln_device_name
      • InputParameter.update()
    • InputParameterLow
      • InputParameterLow.mccs_subarray_dev_name
      • InputParameterLow.tmc_mccs_sln_device_name
      • InputParameterLow.update()
    • InputParameterMid
      • InputParameterMid.dish_dev_names
      • InputParameterMid.tmc_dish_ln_device_names
      • InputParameterMid.update()
  • Module contents

Submodules

subarraynode_node

Path: src/ska_tmc_subarraynode/subarray_node.py

Subarray Node Provides the monitoring and control interface required by users as well as other TM Components (such as OET, Central Node) for a Subarray.

class ska_tmc_subarraynode.subarray_node.BaseSubarrayNode(*args, **kwargs)

Bases: SKASubarray, TMCBaseDevice

Provides the monitoring and control interface required by users as well as other TM Components (such as OET, Central Node) for a Subarray.

BaseSubarrayNode class is inherited from SKASubarray class and TMCBaseDevice class. TMCBaseDevice class is further inherited from SKABaseDevice class.

Common attributes and device_properties within TMC nodes are getting inherited from TMCBaseDevice.

Device Properties

SdpSubarrayLNFQDN:

This property contains the FQDN of the SDP Subarray Leaf Node associated with the Subarray Node.

CspSubarrayLNFQDN:

This property contains the FQDN of the CSP Subarray Leaf Node associated with the Subarray Node.

CspSubarrayFQDN:

FQDN of the CSP Subarray Tango Device Server.

SdpSubarrayFQDN:

FQDN of the SDP Subarray Tango Device Server.

Device Attributes

scanID:

ID of ongoing SCAN

sbID:

ID of ongoing Scheduling Block

isSubarrayAvailable:

Shows availability of subarray device

class InitCommand(*args, **kwargs)

Bases: InitCommand

A class for the TMC SubarrayNode’s init_device() method.

do()

Initializes the attributes and properties of the Subarray Node.

Returns

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

rtype:

(ReturnCode, str)

Raises

DevFailed if the error while subscribing the tango attribute –

Off()

Invokes Off command on SubarrayNode

On()

Invokes On command on SubarrayNode

Standby()

Invokes Standby command on SubarrayNode

always_executed_hook()

Internal construct of TANGO.

create_component_manager()

Create component manager object for command invocation.

delete_device()

init_command_objects()

Initialises the command handlers for commands supported by this device.

internalModel_read()

is_Abort_allowed()

Check if command Abort is allowed in the current device state.

Returns

True if the command is allowed

Return type

boolean

is_AssignResources_allowed()

Return whether the AssignResource command may be called in the current state.

Returns

whether the command may be called in the current device state

Return type

bool

is_Configure_allowed()

Check if command Configure is allowed in the current device state.

Returns

True if the command is allowed

Return type

boolean

is_EndScan_allowed()

Check if command EndScan is allowed in the current device state.

Returns

True if the command is allowed

Return type

boolean

is_End_allowed()

Check if command End is allowed in the current device state.

Returns

True if the command is allowed

Return type

boolean

is_Off_allowed()

Checks whether the command is allowed to be run in the current state

Returns

True if this command is allowed to be run in current device state, False otherwise,

Return type

boolean

Raises

DevFailed if this command is not allowed to be run in current device state

is_On_allowed()

Checks whether the command is allowed to be run in the current state

Returns

True if this command is allowed to be run in current device state, False otherwise.

Return type

boolean

Raises

DevFailed if this command is not allowed to be run in current device state

is_ReleaseAllResources_allowed()

Check if command ReleaseAllResources is allowed in the current device state.

Returns

True if the command is allowed

Return type

boolean

is_Restart_allowed()

Check if command Restart is allowed in the current device state.

Returns

True if the command is allowed

Return type

boolean

is_Scan_allowed()

Check if command Scan is allowed in the current device state.

Returns

True if the command is allowed

Return type

boolean

is_SetAdminMode_allowed()

Check if command Restart is allowed in the current device state.

Returns

True if the command is allowed

Return type

boolean

is_Standby_allowed()

Checks whether the command is allowed to be run in the current state

Returns

True if this command is allowed to be run in current device state, False otherwise.

Return type

boolean

Raises

DevFailed if this command is not allowed to be run in current device state

read_assignedResources()

Returns assignedResources attribute value.

read_isAdminModeEnabled()

Return the isAdminModeEnabled attribute value

Return type

bool

read_isSubarrayAvailable()

Return the TMC Subarray availability status. True/False

read_sbID()

Internal construct of TANGO. Returns the scheduling block ID.

read_scanID()

Internal construct of TANGO. Returns the Scan ID.

EXAMPLE: 123

Where 123 is a Scan ID from configuration json string.

scanDuration()

This attribute is used for exposing the scan duration of ongoing scan to other subsystems. :rtype: float :return: str

transformedInternalModel_read()

update_assigned_resources_callback(assigned_resources)

Triggers a push change event for the assigned resources.

update_device_callback(dev_info)

Updates the last device information changed and triggers a push change event.

update_scan_duration_callback(scan_duration)

Triggers a push change event for the change in scan duration. :type scan_duration: float :param scan_duration: scan duration :type scan_duration: float

Return type

None

update_subarray_availability_status_callback(subarray_availability)

Triggers a push change event for the isSubarrayAvailable.

update_subarray_health_state_callback(subarray_health_state)

This method updates the subarray health state and triggers a push change event.

write_isAdminModeEnabled(value)

Set the value of isAdminModeEnabled attribute

subarraynode_node_low

Path: src/ska_tmc_subarraynode/subarray_node_low.py

Subarray Node Low provides the monitoring and control interface required by users as well as other TM Components (such as OET, Central Node) for a Subarray Low.

class ska_tmc_subarraynode.subarray_node_low.LowTmcSubarray(*args, **kwargs)

Bases: BaseSubarrayNode

Provides the monitoring and control interface required by users as well as other TM Components (such as OET, Central Node) for a Subarray.

Device Properties

MccsSubarrayLNFQDN:

This property contains the FQDN of the MCCS Subarray Leaf Node associated with the Subarray Node.

MccsSubarrayFQDN:

This property contains the FQDN of the MCCS Subarray associated with the Subarray Node.

Device Attributes

class InitCommand(*args, **kwargs)

Bases: InitCommand

A class for the TMC LowTmcSubarray’s init_device() method.

do()

Initializes the attributes and properties of the Subarray Node Mid.

Returns

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

rtype:

(ReturnCode, str)

Raises

DevFailed if the error while subscribing the tango attribute –

create_component_manager()

create instance of component manager

ska_tmc_subarraynode.subarray_node_low.main(args=None, **kwargs)

Runs the LowTmcSubarray. :type args: :param args: Arguments internal to TANGO :type kwargs: :param kwargs: Arguments internal to TANGO :return: LowTmcSubarray TANGO object.

subarraynode_node_mid

Path: src/ska_tmc_subarraynode/subarray_node_mid.py

Subarray Node Mid provides the monitoring and control interface required by users as well as other TM Components (such as OET, Central Node) for a Subarray Mid.

class ska_tmc_subarraynode.subarray_node_mid.MidTmcSubarray(*args, **kwargs)

Bases: BaseSubarrayNode

Provides the monitoring and control interface required by users as well as other TM Components (such as OET, Central Node) for a Subarray.

Device Properties

DishLeafNodePrefix:

Device name prefix for the Dish Leaf Node.

Device Attributes

class InitCommand(*args, **kwargs)

Bases: InitCommand

A class for the TMC MidTmcSubarray’s init_device() method.

do()

Initializes the attributes and properties of the

Subarray Node Mid.

Returns

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

rtype:

(ReturnCode, str)

Raises

DevFailed if the error while subscribing the tango attribute –

create_component_manager()

Create component manager object for command invocation.

ska_tmc_subarraynode.subarray_node_mid.main(args=None, **kwargs)

Runs the SubarrayNode. :type args: :param args: Arguments internal to TANGO :type kwargs: :param kwargs: Arguments internal to TANGO :return: SubarrayNode TANGO object.

exceptions

Path: src/ska_tmc_subarraynode/exceptions.py

This module has custom exception for repository ska_tmc_subarraynode

exception ska_tmc_subarraynode.exceptions.CommandNotAllowed

Bases: Exception

Raised when a command is not allowed.

exception ska_tmc_subarraynode.exceptions.DeviceUnresponsive

Bases: Exception

Raised when a device is not responsive.

exception ska_tmc_subarraynode.exceptions.InvalidObsStateError

Bases: ValueError

Raised when subarray is not in required obsState.

release

Path: src/ska_tmc_subarraynode/release.py

Release information for Python Package

transaction_id

Path: src/ska_tmc_subarraynode/transaction_id.py

This module is for identifing and changing the transaction ids

ska_tmc_subarraynode.transaction_id.identify_with_id(name, arg_name)

This method decorator that identifies a transaction with a unique ID and adds it to the wrapped function’s object.

ska_tmc_subarraynode.transaction_id.inject_id(obj, data)

This method injecting a transaction id

Return type

Dict

ska_tmc_subarraynode.transaction_id.inject_with_id(arg_position, arg_name)

For this method A decorator that injects an ID field into a dictionary-like argument of a function.

ska_tmc_subarraynode.transaction_id.update_with_id(obj, parameters)

Updates the given dictionary-like obj with an ID field and the values in parameters.

Return type

Union[Dict, str]

Module contents

Properties in Subarray Node

Property Name	Data Type	Description
CspSubarrayLNFQDN	DevString	FQDN of the CSP Subarray Leaf Node device
SdpSubarrayLNFQDN	DevString	FQDN of the SDP Subarray Leaf Node device
CspSubarrayFQDN	DevString	FQDN of the CSP Subarray device
SdpSubarrayFQDN	DevString	FQDN of the SDP Subarray device
AbortCommandTimeOut	DevUShort	Timeout for the Subarray ABORTED obsState transition. Once the AbortCommandTimeOut exceeds, SubarrayNode transitions to obsState FAULT.
CspScanInterfaceURL	DevString	Interface URL of the CSP sub-system for Scan command
SdpScanInterfaceURL	DevString	Interface URL of the SDP sub-system for Scan command
CspAssignResourcesInterfaceURL	DevString	Interface URL of the CSP sub-system for AssignResources command
CommandTimeOut	DevUShort	Timeout for the command execution
LivelinessCheckPeriod	DevFloat	Period for the liveliness probe to monitor each device in a loop
EventSubscriptionCheckPeriod	DevFloat	Period for the event subscriber to check the device subscriptions in a loop

Additional Properties in Subarray Node Mid

Property Name	Data Type	Description
DishLeafNodePrefix	DevString	Device name prefix for Dish Leaf Node. This property is for internal use.
DishMasterIdentifier	DevString	Device name tag/identifier for Dish Master device. This property is for internal use.
DishMasterFQDNs	DevStringArray	List of Dish Master devices. This property derived from the values of properties DishIDs and DishMasterIdentifier. It is for internal use.

Additional Properties in Subarray Node Low

Property Name	Data Type	Description
MccsSubarrayLNFQDN	DevString	FQDN of the MCCS Subarray Leaf Node Tango Device Server
MccsSubarrayFQDN	DevString	FQDN of the MCCS Subarray device
MccsConfigureInterfaceURL	DevString	Interface URL of the MCCS sub-system for Configure command
MccsScanInterfaceURL	DevString	Interface URL of the MCCS sub-system for Scan command
JonesURI	DevString	URI for Jones Matrix