@@ -51,7 +51,7 @@ def reconstruct_fink_schema(fink_source, fink_object):
5151
5252def reconstruct_lsst_schema (section , name ):
5353 """ """
54- section_reconstructed = [add_prefix_section (dic , "pred." ) for dic in section ]
54+ section_reconstructed = [add_prefix_section (dic , name ) for dic in section ]
5555 return section_reconstructed
5656
5757
@@ -518,6 +518,7 @@ def extract_schema(payload: dict) -> Response:
518518 ),
519519 }
520520 elif payload ["endpoint" ] == "/api/v1/sso" :
521+ # FIXME: where mpc_orbots goes???
521522 types = {
522523 "LSST original fields (r:)" : sort_dict (
523524 {
@@ -597,10 +598,10 @@ def extract_schema(payload: dict) -> Response:
597598 }
598599 elif payload ["endpoint" ] == "/datatransfer/lsst" :
599600 all_fields = (
600- reconstruct_lsst_schema (diaObject_schema , "diaObject" )
601- + reconstruct_lsst_schema (diaSource_schema , "diaSource" )
602- + reconstruct_lsst_schema (ssSource_schema , "ssSource" )
603- + reconstruct_lsst_schema (mpc_orbits_schema , "mpc_orbits" )
601+ reconstruct_lsst_schema (diaObject_schema , "diaObject. " )
602+ + reconstruct_lsst_schema (diaSource_schema , "diaSource. " )
603+ + reconstruct_lsst_schema (ssSource_schema , "ssSource. " )
604+ + reconstruct_lsst_schema (mpc_orbits_schema , "mpc_orbits. " )
604605 )
605606 types = {
606607 "LSST" : sort_dict (
@@ -614,7 +615,6 @@ def extract_schema(payload: dict) -> Response:
614615 ),
615616 }
616617 else :
617- # FIXME: /stats is missing...
618618 # FIXME: /gw is missing...
619619 msg = "{} is not a valid endpoint" .format (payload ["endpoint" ])
620620 _LOG .warning (msg )
0 commit comments