Changeset 6921


Ignore:
Timestamp:
02/06/10 22:09:01 (9 years ago)
Author:
astephen
Message:

updated processes

Location:
cows_wps/trunk/process_modules
Files:
2 edited

Legend:

Unmodified
Added
Removed
  • cows_wps/trunk/process_modules/extract_uk_station_data.py

    r6910 r6921  
    6767 
    6868            # Call code to get Weather Stations and write file 
    69 #            st_getter = getStations.StationIDGetter(Counties, bbox=BBox, dataTypes=DataTypes, 
    70 #                       startTime=StartDateTime, endTime=EndDateTime, outputFile=sf_path, noprint=1) 
    71 #            StationIDs = st_getter.stList 
    7269            StationIDs.sort() 
    7370 
     
    109106        output_file_paths = exuk_utils.extractStationDataByTimeChunk([ObsTableName], StartDateTime, EndDateTime, 
    110107                       StationIDs, TimeChunk, df_path_base, ext, process_tmp_dir) 
    111 #        startTime12Chars = StartDateTime[:-2] 
    112 #        endTime12Chars = EndDateTime[:-2] 
    113  
    114 #        midasSubsetter.MIDASSubsetter([ObsTableName], df_path, startTime=startTime12Chars,  
    115 #                       endTime=endTime12Chars, src_ids=StationIDs,  
    116 #                       tempDir=process_tmp_dir) 
    117108        
    118109        for df_path in output_file_paths:  
     
    133124    def dryRun(self, context): 
    134125 
    135         # Not implemented for sync jobs 
    136         pass 
     126        self.fileSet = context.outputs['FileSet'] = FileSet() 
     127        self.fileSet.contents.append(FileSet(FLAG.DATA, "testfile.txt", 30000, "Some file")) 
    137128 
     129        ddp_process_support.finishDryRun(context, [("meta", "data")], self.fileSet, 
     130                                         60, acceptedMessage='Dry run complete') 
     131 
  • cows_wps/trunk/process_modules/get_weather_stations.py

    r6877 r6921  
    1515from cows_wps.process_handler.context.process_status import STATUS 
    1616 
    17 #sys.path.append("/usr/local/cwps/cows_wps") 
    1817import process_modules.lib_get_weather_stations.utils as gws_utils 
    1918 
    20 # Import local modules 
    21 #sys.path.append("/home/badc/software/datasets/ukmo-midas/scripts/extract") 
    22 # MIDAS Station search code 
    23 #import getStations 
    2419 
    2520log = logging.getLogger(__name__) 
     
    6055        station_list = gws_utils.getStationList(Counties, BBox, DataTypes, StartDateTime, 
    6156                           EndDateTime, MyFilePath) 
    62 #        st_getter = getStations.StationIDGetter(Counties, bbox=BBox, dataTypes=DataTypes,  
    63 #                       startTime=StartDateTime, endTime=EndDateTime, outputFile=MyFilePath, noprint=1)  
    6457 
    6558        context.outputs['ProcessSpecificContent'] = { 
     
    8174 
    8275        self.fileSet = context.outputs['FileSet'] = FileSet() 
    83         self.fileSet.contents.append(FileSet(FLAG.DATA, "testfile.txt", 30000, "Soem file")) 
     76        self.fileSet.contents.append(FileSet(FLAG.DATA, "testfile.txt", 30000, "Some file")) 
    8477         
    8578        ddp_process_support.finishDryRun(context, [("meta", "data")], self.fileSet, 
Note: See TracChangeset for help on using the changeset viewer.