Index

A

add_phase() (ska_sdp_scripting.processing_block.ProcessingBlock method)

allocations (ska_sdp_scripting.receive_addresses.receive_addresses.ReceiveAddressesBase attribute)

B

BufferRequest (class in ska_sdp_scripting.buffer_request)

C

channels_per_port (ska_sdp_scripting.receive_addresses.receive_addresses.ReceiveAddressesBase attribute) check_realtime (ska_sdp_scripting.phase.Phase.check_state parameter) check_resource_allocation() (ska_sdp_scripting.phase.Phase method) check_state() (ska_sdp_scripting.phase.Phase method) config (ska_sdp_scripting.dask_deploy.DaskDeploy parameter) (ska_sdp_scripting.ee_base_deploy.EEDeploy parameter) (ska_sdp_scripting.fake_deploy.FakeDeploy parameter) (ska_sdp_scripting.helm_deploy.HelmDeploy parameter) (ska_sdp_scripting.phase.Phase parameter) (ska_sdp_scripting.queue_connector.wait_for_queue_connector_state parameter) (ska_sdp_scripting.slurm_deploy.SlurmDeploy parameter)

copy_beam_info_from_eb() (in module ska_sdp_scripting.receive_addresses.receive_addresses) create_data_flow() (ska_sdp_scripting.processing_block.ProcessingBlock method) create_flow_dependency() (ska_sdp_scripting.processing_block.ProcessingBlock method) create_phase() (ska_sdp_scripting.processing_block.ProcessingBlock method) create_sdm_flow() (ska_sdp_scripting.processing_block.ProcessingBlock method)

D

DaskDeploy (class in ska_sdp_scripting.dask_deploy) data_model (ska_sdp_scripting.processing_block.ProcessingBlock.create_data_flow parameter) default_parameters (ska_sdp_scripting.processing_block.ProcessingBlock.update_parameters parameter) dependencies (ska_sdp_scripting.phase.Phase parameter) (ska_sdp_scripting.processing_block.ProcessingBlock.create_phase parameter) deploy_id (ska_sdp_scripting.ee_base_deploy.EEDeploy property) (ska_sdp_scripting.ee_base_deploy.EEDeploy.remove parameter)

deploy_name (ska_sdp_scripting.dask_deploy.DaskDeploy parameter) (ska_sdp_scripting.fake_deploy.FakeDeploy parameter) (ska_sdp_scripting.helm_deploy.HelmDeploy parameter) (ska_sdp_scripting.phase.Phase.ee_deploy_helm parameter) (ska_sdp_scripting.phase.Phase.ee_deploy_slurm parameter) (ska_sdp_scripting.phase.Phase.ee_deploy_test parameter) (ska_sdp_scripting.slurm_deploy.SlurmDeploy parameter)

E

eb (ska_sdp_scripting.processing_block.ProcessingBlock property) eb_id (ska_sdp_scripting.phase.Phase parameter) (ska_sdp_scripting.processing_block.ProcessingBlock property) ee_deploy_dask() (ska_sdp_scripting.phase.Phase method) ee_deploy_helm() (ska_sdp_scripting.phase.Phase method) ee_deploy_slurm() (ska_sdp_scripting.phase.Phase method)

ee_deploy_test() (ska_sdp_scripting.phase.Phase method) EEDeploy (class in ska_sdp_scripting.ee_base_deploy) expected_state (ska_sdp_scripting.queue_connector.wait_for_queue_connector_state parameter) expiry_time (ska_sdp_scripting.processing_block.ProcessingBlock.create_data_flow parameter) (ska_sdp_scripting.processing_block.ProcessingBlock.create_sdm_flow parameter) extra_values (ska_sdp_scripting.receive_addresses.receive_addresses.ReceiveAddresses attribute)

F

f_args (ska_sdp_scripting.dask_deploy.DaskDeploy parameter) (ska_sdp_scripting.fake_deploy.FakeDeploy parameter) (ska_sdp_scripting.phase.Phase.ee_deploy_dask parameter) (ska_sdp_scripting.phase.Phase.ee_deploy_test parameter) FakeDeploy (class in ska_sdp_scripting.fake_deploy)

flow_data (ska_sdp_scripting.phase.Phase parameter) func (ska_sdp_scripting.dask_deploy.DaskDeploy parameter) (ska_sdp_scripting.fake_deploy.FakeDeploy parameter) (ska_sdp_scripting.phase.Phase.ee_deploy_dask parameter) (ska_sdp_scripting.phase.Phase.ee_deploy_test parameter) (ska_sdp_scripting.phase.Phase.wait_loop parameter)

G

generate() (ska_sdp_scripting.receive_addresses.receive_addresses.PartialReceiveAddresses static method) generate_receive_addresses() (ska_sdp_scripting.processing_block.ProcessingBlock method) get_dependencies() (ska_sdp_scripting.processing_block.ProcessingBlock method)

get_parameters() (ska_sdp_scripting.processing_block.ProcessingBlock method) get_scan_types() (ska_sdp_scripting.processing_block.ProcessingBlock method) grace_period (ska_sdp_scripting.phase.Phase.is_eb_and_processing_finished parameter)

H

HelmDeploy (class in ska_sdp_scripting.helm_deploy)

host_count (ska_sdp_scripting.receive_addresses.receive_addresses.ReceiveAddressesBase property) hosts (ska_sdp_scripting.receive_addresses.receive_addresses.ReceiveAddressesBase property)

I

is_eb_and_processing_finished() (ska_sdp_scripting.phase.Phase method) is_finished() (ska_sdp_scripting.ee_base_deploy.EEDeploy method)

iteration (ska_sdp_scripting.phase.Phase.monitor_data_flows parameter) (ska_sdp_scripting.phase.Phase.monitor_deployments parameter)

K

kind (ska_sdp_scripting.buffer_request.BufferRequest parameter) (ska_sdp_scripting.processing_block.ProcessingBlock.request_buffer parameter)

L

length (ska_sdp_scripting.processing_block.ProcessingBlock.add_phase parameter) (ska_sdp_scripting.processing_block.ProcessingBlock.update_phase parameter)

list_requests (ska_sdp_scripting.phase.Phase parameter)

M

max_port_count (ska_sdp_scripting.receive_addresses.receive_addresses.ReceiveAddressesBase property) module ska_sdp_scripting.queue_connector ska_sdp_scripting.receive_addresses.receive_addresses

monitor_data_flows() (ska_sdp_scripting.phase.Phase method) monitor_deployments() (ska_sdp_scripting.phase.Phase method)

N

n_workers (ska_sdp_scripting.dask_deploy.DaskDeploy parameter) (ska_sdp_scripting.phase.Phase.ee_deploy_dask parameter) name (ska_sdp_scripting.buffer_request.BufferRequest parameter) (ska_sdp_scripting.phase.Phase parameter) (ska_sdp_scripting.phase.Phase.ee_deploy_dask parameter) (ska_sdp_scripting.processing_block.ProcessingBlock.create_data_flow parameter) (ska_sdp_scripting.processing_block.ProcessingBlock.create_phase parameter) (ska_sdp_scripting.processing_block.ProcessingBlock.create_sdm_flow parameter) (ska_sdp_scripting.processing_block.ProcessingBlock.request_buffer parameter)

O

output_path (ska_sdp_scripting.processing_block.ProcessingBlock.create_sdm_flow parameter)

P

parameters (ska_sdp_scripting.processing_block.ProcessingBlock.create_sdm_flow parameter) (ska_sdp_scripting.processing_block.ProcessingBlock.update_parameters parameter) PartialReceiveAddresses (class in ska_sdp_scripting.receive_addresses.receive_addresses) pb_id (ska_sdp_scripting.buffer_request.BufferRequest parameter) (ska_sdp_scripting.dask_deploy.DaskDeploy parameter) (ska_sdp_scripting.ee_base_deploy.EEDeploy parameter) (ska_sdp_scripting.fake_deploy.FakeDeploy parameter) (ska_sdp_scripting.helm_deploy.HelmDeploy parameter) (ska_sdp_scripting.phase.Phase parameter) (ska_sdp_scripting.processing_block.ProcessingBlock parameter) (ska_sdp_scripting.processing_block.ProcessingBlock property) (ska_sdp_scripting.queue_connector.wait_for_queue_connector_state parameter) (ska_sdp_scripting.slurm_deploy.SlurmDeploy parameter)

Phase (class in ska_sdp_scripting.phase) phase_name (ska_sdp_scripting.processing_block.ProcessingBlock.add_phase parameter) (ska_sdp_scripting.processing_block.ProcessingBlock.update_phase parameter) phases (ska_sdp_scripting.buffer_request.BufferRequest parameter) (ska_sdp_scripting.processing_block.ProcessingBlock.request_buffer parameter) port_counts (ska_sdp_scripting.receive_addresses.receive_addresses.ReceiveAddressesBase property) ProcessingBlock (class in ska_sdp_scripting.processing_block) publish_receive_addresses() (ska_sdp_scripting.processing_block.ProcessingBlock method)

R

receive_addresses (ska_sdp_scripting.processing_block.ProcessingBlock.publish_receive_addresses parameter) ReceiveAddresses (class in ska_sdp_scripting.receive_addresses.receive_addresses) ReceiveAddressesBase (class in ska_sdp_scripting.receive_addresses.receive_addresses) remove() (ska_sdp_scripting.ee_base_deploy.EEDeploy method)

replace_hosts() (ska_sdp_scripting.receive_addresses.receive_addresses.PartialReceiveAddresses method) request_buffer() (ska_sdp_scripting.processing_block.ProcessingBlock method) request_key (ska_sdp_scripting.buffer_request.BufferRequest property) requests (ska_sdp_scripting.processing_block.ProcessingBlock.create_phase parameter) resource_request() (ska_sdp_scripting.buffer_request.BufferRequest method)

S

script_kind (ska_sdp_scripting.phase.Phase parameter) set_deployments_ready() (ska_sdp_scripting.fake_deploy.FakeDeploy method) set_phases() (ska_sdp_scripting.processing_block.ProcessingBlock method) sink (ska_sdp_scripting.processing_block.ProcessingBlock.create_data_flow parameter) size (ska_sdp_scripting.buffer_request.BufferRequest parameter) (ska_sdp_scripting.processing_block.ProcessingBlock.request_buffer parameter) ska_sdp_scripting.queue_connector module ska_sdp_scripting.receive_addresses.receive_addresses module

slargs (ska_sdp_scripting.phase.Phase.ee_deploy_slurm parameter) (ska_sdp_scripting.slurm_deploy.SlurmDeploy parameter) SlurmDeploy (class in ska_sdp_scripting.slurm_deploy) sources (ska_sdp_scripting.processing_block.ProcessingBlock.create_data_flow parameter) status (ska_sdp_scripting.ee_base_deploy.EEDeploy.update_deploy_status parameter) (ska_sdp_scripting.phase.Phase.update_pb_state parameter) (ska_sdp_scripting.processing_block.ProcessingBlock.add_phase parameter) (ska_sdp_scripting.processing_block.ProcessingBlock.update_phase parameter) subarray_id (ska_sdp_scripting.processing_block.ProcessingBlock property)

T

time_to_ready (ska_sdp_scripting.fake_deploy.FakeDeploy.set_deployments_ready parameter) (ska_sdp_scripting.phase.Phase.wait_loop parameter) timeout (ska_sdp_scripting.queue_connector.wait_for_queue_connector_state parameter) to_recv_addresses_dict() (ska_sdp_scripting.receive_addresses.receive_addresses.ReceiveAddresses method) (ska_sdp_scripting.receive_addresses.receive_addresses.ReceiveAddressesBase method)

txn (ska_sdp_scripting.ee_base_deploy.EEDeploy.is_finished parameter) (ska_sdp_scripting.phase.Phase.check_state parameter) (ska_sdp_scripting.phase.Phase.is_eb_and_processing_finished parameter) (ska_sdp_scripting.phase.Phase.monitor_data_flows parameter) (ska_sdp_scripting.phase.Phase.monitor_deployments parameter)

U

update_deploy_status() (ska_sdp_scripting.ee_base_deploy.EEDeploy method) update_parameters() (ska_sdp_scripting.processing_block.ProcessingBlock method)

update_pb_state() (ska_sdp_scripting.phase.Phase method) update_phase() (ska_sdp_scripting.processing_block.ProcessingBlock method)

V

validate_parameters() (ska_sdp_scripting.processing_block.ProcessingBlock method) values (ska_sdp_scripting.helm_deploy.HelmDeploy parameter) (ska_sdp_scripting.phase.Phase.ee_deploy_helm parameter)

version (ska_sdp_scripting.phase.Phase.ee_deploy_helm parameter)

W

wait_for_queue_connector_state() (in module ska_sdp_scripting.queue_connector)

wait_loop() (ska_sdp_scripting.phase.Phase method)