gridding

Module for orchestrating gridding tasks.

class ska_sdp_distributed_self_cal_prototype.processing_tasks.gridding.Gridder(config: PipelineConfig)[source]

Bases: object

Class that stores the gridding kernel and orchestrates gridding tasks.

Parameters:

config – Config describing the pipeline.

property config

Returns the config attribute.

get_kernel() → ska_sdp_func.grid_data.gridder_wtower_uvw.GridderWtowerUVW[source]

Creates a new instance of the gridding kernel.

Returns:

The gridding kernel used for correcting facet images.

Return type:

kernel

grid_psf(swiftly_manager: Swiftly, visibility_bins: list[ska_sdp_distributed_self_cal_prototype.data_managers.visibility_bin.VisibilityBin], subgrid_size: int, min_frequency: float, channel_width: float) → None[source]

Add gridding tasks for psf for multiple subgrids to SwiFTly.

This function generates and adds tasks for gridding psf data onto subgrids, where each task processes a portion of the UVW coordinates and psf data.

Parameters:

  • swiftly_manager – Swiftly manager for the pipeline.

  • visibility_bins – List of VisibilityBin objects holding binned visibility data.

  • subgrid_size – Size of subgrids.

  • min_frequency – Minimum frequency in Hz across dataset.

  • channel_width – Channel width in Hz.

Returns:

None.

grid_visibilities(swiftly_manager: Swiftly, visibility_bins: list[ska_sdp_distributed_self_cal_prototype.data_managers.visibility_bin.VisibilityBin], subgrid_size: int, min_frequency: float, channel_width: float) → None[source]

Add gridding tasks for multiple subgrids to SwiFTly.

This function generates and adds tasks for gridding data onto subgrids, where each task processes a portion of the UVW coordinates and visibility data.

Parameters:

  • swiftly_manager – Swiftly manager for the pipeline.

  • visibility_bins – List of VisibilityBin objects holding binned visibility data.

  • subgrid_size – Size of subgrids.

  • min_frequency – Minimum frequency in Hz across dataset.

  • channel_width – Channel width in Hz.

Returns:

None.

predict_residual_visibilities(swiftly_manager: Swiftly, visibility_bins_to_update: list[ska_sdp_distributed_self_cal_prototype.data_managers.visibility_bin.VisibilityBin], channel_count: int, min_frequency: float, channel_width: float) → list[ska_sdp_distributed_self_cal_prototype.data_managers.visibility_bin.VisibilityBin][source]

Add degridding tasks for multiple subgrids from SwiFTly.

This function generates and adds tasks for degridding data from subgrids, via swiftly, where each task produces a portion of the visibility data. Uses subgrid config stored in swiftly manager to define subgrids.

Parameters:

  • swiftly_manager – Swiftly manager with facet tasks

  • visibility_bins – List of VisibilityBin objects containing binned visibility data.

  • channel_count – Number of channels.

  • min_frequency – Minimum frequency (Hz).

  • channel_width – Channel width (Hz).

Returns:

List of VisibilityBin objects containing tasks to predict model visibilities.

Return type:

visibility_bins