lsst.pipe.tasks.ssp.sssource Namespace Reference

Functions
	compute_sssource_entry (sss, assoc, mpcorb, dia)

Variables
str	input_dir = "./analysis/inputs"
str	output_dir = "./analysis/outputs"
	dia
	det
	sampled_provids = det["provid"].drop_duplicates().sample(10, random_state=42)
	expect_dtypes
tuple	assoc
	columns
	inplace
	totalNumObs = len(assoc)
	numid
	curid
tuple	df = assoc[["mpc_provid", "mpc_permid"]].merge(numid, left_on="mpc_permid", right_on="permid", how="left")
	sss = np.zeros(totalNumObs, dtype=schema.SSSourceDtype)
	ra
	dec
	t
	p = SkyCoord(ra=ra * u.deg, dec=dec * u.deg, distance=1 * u.au, frame="hcrs")
	ecl = p.transform_to(HeliocentricEclipticIAU76)
	gal = p.transform_to("galactic")
	mpcorb
	totalNumObjects = np.unique(sss["ssObjectId"]).size

Function Documentation

compute_sssource_entry()

lsst.pipe.tasks.ssp.sssource.compute_sssource_entry	(		sss,
			assoc,
			mpcorb,
			dia )

Definition at line 18 of file sssource.py.

Variable Documentation

assoc

tuple lsst.pipe.tasks.ssp.sssource.assoc

Initial value:

=  (
        dia[["diaSourceId"]]
        .reset_index()
        .merge(det.add_prefix("mpc_"), left_on="diaSourceId", right_on="mpc_obssubid", how="inner")
    )

Definition at line 157 of file sssource.py.

columns

lsst.pipe.tasks.ssp.sssource.columns

Definition at line 162 of file sssource.py.

curid

lsst.pipe.tasks.ssp.sssource.curid

Initial value:

=  pd.read_parquet(
        f"{input_dir}/current_identifications.parquet",
        engine="pyarrow",
        dtype_backend="pyarrow",
        columns=[
            "unpacked_primary_provisional_designation",
            "unpacked_secondary_provisional_designation",
            "packed_primary_provisional_designation",
        ],
    ).reset_index(drop=True)

Definition at line 178 of file sssource.py.

dec

lsst.pipe.tasks.ssp.sssource.dec

Definition at line 226 of file sssource.py.

det

lsst.pipe.tasks.ssp.sssource.det

Initial value:

=  pd.read_parquet(
        f"{input_dir}/obs_sbn.parquet", engine="pyarrow", dtype_backend="pyarrow"
    ).reset_index()

Definition at line 113 of file sssource.py.

df

tuple lsst.pipe.tasks.ssp.sssource.df = assoc[["mpc_provid", "mpc_permid"]].merge(numid, left_on="mpc_permid", right_on="permid", how="left")

Definition at line 191 of file sssource.py.

dia

lsst.pipe.tasks.ssp.sssource.dia

Initial value:

=  pd.read_parquet(
        f"{input_dir}/dia_sources.parquet", engine="pyarrow", dtype_backend="pyarrow"
    ).reset_index(drop=True)

Definition at line 107 of file sssource.py.

ecl

lsst.pipe.tasks.ssp.sssource.ecl = p.transform_to(HeliocentricEclipticIAU76)

Definition at line 236 of file sssource.py.

expect_dtypes

lsst.pipe.tasks.ssp.sssource.expect_dtypes

Initial value:

=  dict(
        trksub="string[pyarrow]",
        obssubid="int64",
        provid="string[pyarrow]",
        permid="string[pyarrow]",
        submission_id="string[pyarrow]",
        ra="double[pyarrow]",
        dec="double[pyarrow]",
        obstime="timestamp[us][pyarrow]",
        designation_asterisk="bool[pyarrow]",
    )

Definition at line 141 of file sssource.py.

gal

lsst.pipe.tasks.ssp.sssource.gal = p.transform_to("galactic")

Definition at line 238 of file sssource.py.

inplace

lsst.pipe.tasks.ssp.sssource.inplace

Definition at line 162 of file sssource.py.

input_dir

str lsst.pipe.tasks.ssp.sssource.input_dir = "./analysis/inputs"

Definition at line 104 of file sssource.py.

mpcorb

lsst.pipe.tasks.ssp.sssource.mpcorb

Initial value:

=  pd.read_parquet(
        f"{input_dir}/mpc_orbits.parquet",
        engine="pyarrow",
        dtype_backend="pyarrow",
        columns=[
            "unpacked_primary_provisional_designation",
            "packed_primary_provisional_designation",
            "a",
            "q",
            "e",
            "i",
            "node",
            "argperi",
            "peri_time",
            "mean_anomaly",
            "epoch_mjd",
            "h",
            "g",
        ],
    ).reset_index(drop=True)

Definition at line 245 of file sssource.py.

numid

lsst.pipe.tasks.ssp.sssource.numid

Initial value:

=  pd.read_parquet(
        f"{input_dir}/numbered_identifications.parquet",
        engine="pyarrow",
        columns=["permid", "unpacked_primary_provisional_designation"],
        dtype_backend="pyarrow",
    ).reset_index(drop=True)

Definition at line 172 of file sssource.py.

output_dir

str lsst.pipe.tasks.ssp.sssource.output_dir = "./analysis/outputs"

Definition at line 105 of file sssource.py.

p

lsst.pipe.tasks.ssp.sssource.p = SkyCoord(ra=ra * u.deg, dec=dec * u.deg, distance=1 * u.au, frame="hcrs")

Definition at line 235 of file sssource.py.

ra

lsst.pipe.tasks.ssp.sssource.ra

Definition at line 226 of file sssource.py.

sampled_provids

lsst.pipe.tasks.ssp.sssource.sampled_provids = det["provid"].drop_duplicates().sample(10, random_state=42)

Definition at line 118 of file sssource.py.

sss

lsst.pipe.tasks.ssp.sssource.sss = np.zeros(totalNumObs, dtype=schema.SSSourceDtype)

Definition at line 215 of file sssource.py.

t

lsst.pipe.tasks.ssp.sssource.t

Definition at line 226 of file sssource.py.

totalNumObjects

lsst.pipe.tasks.ssp.sssource.totalNumObjects = np.unique(sss["ssObjectId"]).size

Definition at line 268 of file sssource.py.

totalNumObs

lsst.pipe.tasks.ssp.sssource.totalNumObs = len(assoc)

Definition at line 170 of file sssource.py.