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.update_command_in_progress_id()
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.invoke_assign_resources()
AssignResources.set_up_dish_data()
AssignResources.update_task_status()
AssignResources.validate_low_json()
- configure_command
- end_command
- end_scan_command
- release_all_resources_command
ReleaseAllResources
ReleaseAllResources.clean_up_low_resources()
ReleaseAllResources.clean_up_mid_resources()
ReleaseAllResources.do_low()
ReleaseAllResources.do_mid()
ReleaseAllResources.invoke_release_resources()
ReleaseAllResources.release_csp_resources()
ReleaseAllResources.release_sdp_resources()
ReleaseAllResources.update_task_status()
- restart_command
- scan_command
- off_command
- on_command
- Module contents
- subarray_node_command
- ska_tmc_subarraynode.manager package
- Submodules
- aggregators
- event_receiver
SubarrayNodeEventReceiver
SubarrayNodeEventReceiver.check_event_error()
SubarrayNodeEventReceiver.device_attribute_event_ids
SubarrayNodeEventReceiver.handle_assigned_resources_event()
SubarrayNodeEventReceiver.handle_dish_mode_event()
SubarrayNodeEventReceiver.handle_lrcr_event()
SubarrayNodeEventReceiver.handle_pointing_state_event()
SubarrayNodeEventReceiver.handle_receive_addresses_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.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_in_progress
SubarrayNodeComponentManager.component_state_changed_callback_and_logging()
SubarrayNodeComponentManager.configure()
SubarrayNodeComponentManager.devices
SubarrayNodeComponentManager.end()
SubarrayNodeComponentManager.end_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_timer_running()
SubarrayNodeComponentManager.off()
SubarrayNodeComponentManager.on()
SubarrayNodeComponentManager.process_lrcr_event()
SubarrayNodeComponentManager.process_obs_state_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_assigned_resources()
SubarrayNodeComponentManager.set_sb_id()
SubarrayNodeComponentManager.set_scan_duration()
SubarrayNodeComponentManager.set_scan_id()
SubarrayNodeComponentManager.set_subarray_id()
SubarrayNodeComponentManager.stop()
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_dish_mode()
SubarrayNodeComponentManager.update_device_health_state()
SubarrayNodeComponentManager.update_device_obs_state()
SubarrayNodeComponentManager.update_device_ping_failure()
SubarrayNodeComponentManager.update_device_pointing_state()
SubarrayNodeComponentManager.update_device_state()
SubarrayNodeComponentManager.update_event_failure()
SubarrayNodeComponentManager.update_input_parameter()
SubarrayNodeComponentManager.update_long_running_command_result()
SubarrayNodeComponentManager.update_ping_info()
SubarrayNodeComponentManager.update_receive_addresses()
SubarrayNodeComponentManager.update_subarray_availability_status()
SubarrayNodeComponentManager.validate_scan_low_json()
- Module contents
HealthStateAggregatorLow
HealthStateAggregatorMid
ObsStateAggregatorLow
ObsStateAggregatorMid
SubarrayAvailabilityAggregatorLow
SubarrayAvailabilityAggregatorMid
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_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_tmc_dish_ln_device_names()
SubarrayNodeComponentManagerMid.invoke_pointing_calibration()
SubarrayNodeComponentManagerMid.obsreset()
SubarrayNodeComponentManagerMid.pointing_calibrations
SubarrayNodeComponentManagerMid.release()
SubarrayNodeComponentManagerMid.remove_dish_devices()
SubarrayNodeComponentManagerMid.set_dish_device_names()
SubarrayNodeComponentManagerMid.set_keys_required_for_getting_sdpqc_fqdn()
SubarrayNodeComponentManagerMid.set_tmc_leaf_dish_device_names()
SubarrayNodeComponentManagerMid.standby()
SubarrayNodeComponentManagerMid.start_communicating()
SubarrayNodeComponentManagerMid.stop_communicating()
SubarrayNodeEventReceiver
SubarrayNodeEventReceiver.check_event_error()
SubarrayNodeEventReceiver.device_attribute_event_ids
SubarrayNodeEventReceiver.handle_assigned_resources_event()
SubarrayNodeEventReceiver.handle_dish_mode_event()
SubarrayNodeEventReceiver.handle_lrcr_event()
SubarrayNodeEventReceiver.handle_pointing_state_event()
SubarrayNodeEventReceiver.handle_receive_addresses_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
- input module
- Module contents
- component module
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 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()
- 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
- 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_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_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.
- 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_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.
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.SubarrayNodeLow(*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 SubarrayNodeLow’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
- read_mccsSubarrayDevName()
Return the mccsSubarrayDevName attribute.
- read_tmcLeafCspSubarrayDevName()
Return the tmc CSP SubarrayLeafNode Device Name attribute.
- Return type
- read_tmcLeafMccsSubarrayDevName()
Return the tmcLeafMccsSubarrayDevName attribute.
- read_tmcLeafSdpSubarrayDevName()
Return the SDP SubarrayLeafNode Device Name attribute.
- Return type
- write_mccsSubarrayDevName(value)
Set the mccsSubarrayDevName attribute.
- write_tmcLeafCspSubarrayDevName(value)
Set the CSP SubarrayLeafNode Device Name attribute.
- Return type
- write_tmcLeafMccsSubarrayDevName(value)
Set the tmcLeafMccsSubarrayDevName attribute.
- ska_tmc_subarraynode.subarray_node_low.main(args=None, **kwargs)
Runs the SubarrayNodeLow. :type args: :param args: Arguments internal to TANGO :type kwargs: :param kwargs: Arguments internal to TANGO :return: SubarrayNodeLow 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.SubarrayNodeMid(*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
- 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.
- DishLeafNodePrefix:
Device name prefix for the Dish Leaf Node.
- CspSubarrayFQDN:
FQDN of the CSP Subarray Tango Device Server.
- SdpSubarrayFQDN:
FQDN of the CSP Subarray Tango Device Server.
- Device Attributes
- class InitCommand(*args, **kwargs)
Bases:
InitCommand
A class for the TMC SubarrayNodeMid’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 –
- read_cspSubarrayDevName()
Return the CSP subarray device name attribute.
- read_dishDevNames()
Return the dish device names attribute.
- read_sdpSubarrayDevName()
Return the SDP subarray device name attribute.
- read_tmcLeafCspSubarrayDevName()
Return the TMC CSP SubarrayLeafNode Device Name attribute.
- read_tmcLeafDishDevNames()
Return the TMC DishLeafNode Device Name attribute.
- read_tmcLeafSdpSubarrayDevName()
Return the TMC SDP SubarrayLeafNode Device Name attribute.
- write_cspSubarrayDevName(value)
Set the CSP subarray device name attribute.
- write_dishDevNames(value)
Set the dish device names attribute.
- write_sdpSubarrayDevName(value)
Set the SDP subarray device name attribute.
- write_tmcLeafCspSubarrayDevName(value)
Set the TMC CSP SubarrayLeafNode Device Name attribute.
- write_tmcLeafDishDevNames(value)
Set the TMC DishLeafNode Device Name attribute.
- write_tmcLeafSdpSubarrayDevName(value)
Set the TMC SDP SubarrayLeafNode Device Name attribute.
- 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
- 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.