mirar.catalog.kowalski package

Module for catalogs using Kowalski

Submodules

mirar.catalog.kowalski.base_kowalski_catalog module

Module containing the base Kowalski catalog object

class mirar.catalog.kowalski.base_kowalski_catalog.BaseKowalskiXMatch(*args, kowalski: Kowalski | None = None, max_time_ms: float = 10000, **kwargs)[source]

Bases: BaseXMatchCatalog, ABC

Base class for a catalog using Kowalski

near_query_kowalski(coords: dict) → dict[source]

Performs a Kowalski query around coords

Parameters:: coords – ra/dec
Returns:: crossmatch dict

query(coords) → dict[source]

Uses a Kowalski object to query for sources around coords

Parameters:: coords – ra/dec
Returns:: crossmatch sources

static update_data(data: dict) → dict[source]

For a given catalog, update the data with any extra information

Parameters:: data – kowalski data
Returns:: updated data

exception mirar.catalog.kowalski.base_kowalski_catalog.KowalskiError[source]

Bases: ProcessorError

Error relating to Kowalski

mirar.catalog.kowalski.base_kowalski_catalog.get_kowalski() → Kowalski[source]

Get a Kowalski object, using credentials stored in the environment

Returns:: Kowalski object

mirar.catalog.kowalski.ps1 module

Module for querying PS1 using Kowalski

class mirar.catalog.kowalski.ps1.PS1(*args, kowalski: Kowalski | None = None, max_time_ms: float = 10000, **kwargs)[source]

Bases: BaseKowalskiXMatch

PS1 Kowalski catalog

abbreviation = 'ps'

catalog_name = 'PS1_DR1'

column_dtypes = {'psdec': <class 'float'>, 'psobjectid': <class 'float'>, 'psra': <class 'float'>, 'sgmag': <class 'float'>, 'simag': <class 'float'>, 'srmag': <class 'float'>, 'szmag': <class 'float'>}

column_names = {'_id': 'psobjectid', 'decMean': 'psdec', 'gMeanPSFMag': 'sgmag', 'iMeanPSFMag': 'simag', 'rMeanPSFMag': 'srmag', 'raMean': 'psra', 'zMeanPSFMag': 'szmag'}

projection = {'_id': 1, 'decMean': 1, 'gMeanPSFMag': 1, 'iMeanPSFMag': 1, 'rMeanPSFMag': 1, 'raMean': 1, 'zMeanPSFMag': 1}

mirar.catalog.kowalski.tmass module

Module for querying 2MASS using Kowalski

class mirar.catalog.kowalski.tmass.TMASS(*args, kowalski: Kowalski | None = None, max_time_ms: float = 10000, **kwargs)[source]

Bases: BaseKowalskiXMatch

2MASS Kowalski catalog

abbreviation = 'tm'

catalog_name = '2MASS_PSC'

column_dtypes = {'tmdec': <class 'float'>, 'tmhmag': <class 'float'>, 'tmhmagerr': <class 'float'>, 'tmjmag': <class 'float'>, 'tmjmagerr': <class 'float'>, 'tmkmag': <class 'float'>, 'tmkmagerr': <class 'float'>, 'tmobjectid': <class 'str'>, 'tmph_qual': <class 'str'>, 'tmra': <class 'float'>}

column_names = {'decl': 'tmdec', 'designation': 'tmobjectid', 'h_cmsigcom': 'tmhmagerr', 'h_m': 'tmhmag', 'j_m': 'tmjmag', 'j_msigcom': 'tmjmagerr', 'k_cmsigcom': 'tmkmagerr', 'k_m': 'tmkmag', 'ph_qual': 'tmph_qual', 'ra': 'tmra'}

projection = {'_id': 0, 'decl': 1, 'designation': 1, 'h_cmsigcom': 1, 'h_m': 1, 'j_m': 1, 'j_msigcom': 1, 'k_cmsigcom': 1, 'k_m': 1, 'ph_qual': 1, 'ra': 1}

static update_data(data: dict) → dict[source]

For a given catalog, update the data with any extra information

Parameters:: data – kowalski data
Returns:: updated data