Commit 12f448ca authored by niejuzi's avatar niejuzi
Browse files

update code

parent 1f9b88be

csst/msc/calib_pos.py

+11 −11
Original line number Diff line number Diff line
@@ -190,7 +190,7 @@ class CsstProcMscPositionCalibration(CsstProcessor): 
            filename of the cross matched catalog: ref.cat

        """

        outcat = self.dm.pc_ref_cat

        fnmae =  cb_fn = self.dm.pc_combined_file("img","fits")

        fnmae = self.dm.pc_combined_file("img","fits")

        hdu = fits.open(fname)

        header1 = hdu[0].header

        header2 = hdu[1].header
@@ -431,16 +431,16 @@ class CsstProcMscPositionCalibration(CsstProcessor): 
    def run(self, img_list, wht_list, flg_list, ccd_ids, path_gaia, search_radius, pm_correct=True, wcs_refine=False, plot=False):

        print('preparing files for position calibration....')

        #self.join_data(img_list, wht_list, flg_list)

        print('################## run sextractor ###################')

        p = Pool()

        prod_x = partial(self.run_sextractor)

        result = p.map(prod_x, ccd_ids)

        p.close()

        p.join()

        print('################## sextractor done ###################')

        print('############### combine sextractor catalog ###############')

        self.combine_catalog(ccd_ids)

        print('############### get reference catalog ###############3')

        #print('################## run sextractor ###################')

        #p = Pool()

        #prod_x = partial(self.run_sextractor)

        #result = p.map(prod_x, ccd_ids)

        #p.close()

        #p.join()

        #print('################## sextractor done ###################')

        #print('############### combine sextractor catalog ###############')

        #self.combine_catalog(ccd_ids)

        #print('############### get reference catalog ###############3')

        self.get_refcat(img_list, path_gaia=path_gaia, search_radius=search_radius, silent=True,pm_correct=True)

        print('############### run scamp ##################')

        self.run_scamp(wcs_refine=wcs_refine)