Changeset 7068 for cows_wps


Ignore:
Timestamp:
24/06/10 09:12:36 (9 years ago)
Author:
astephen
Message:

tidying

Location:
cows_wps/trunk
Files:
3 edited

Legend:

Unmodified
Added
Removed
  • cows_wps/trunk/cows_wps/controllers/jobviewer.py

    r7020 r7068  
    116116 
    117117        if self.status == "complete": 
    118             mapped_names.extend(["Job Duration (seconds)", "Output Size (bytes)"]) 
     118            mapped_names.extend(["Job Duration", "Output Size"]) 
    119119        else: 
    120             mapped_names.extend(["Estimated Job Duration (seconds)", "Estimated Output Size (bytes)"]) 
     120            mapped_names.extend(["Estimated Job Duration", "Estimated Output Size"]) 
    121121 
    122122        resp = "<h2>DETAILS</h2>" 
     
    130130 
    131131            x = x.strip() 
     132 
    132133            if item == "JobCapabilities" and x.find("send_to_extract_weather_data") > -1: 
    133134                file_url = file_set_list[0].find("{" + self.namespace +  "}FileURL").text 
     
    137138                x = x.replace("send_to_extract_weather_data", 
    138139                  '<a href="/submit/form?proc_id=ExtractUKStationData&StationsFile=%s">Use stations to extract UK weather data</a>' % file_path)  
     140 
     141            elif item == "JobVolume": 
     142                x = self._toMB(x) 
     143 
     144            elif item == "JobDuration": 
     145                secs = int(float(x)) 
     146                secs = secs or 1 
     147                ext = "" 
     148                if secs > 1: ext = "s" 
     149                x = "%d second%s" % (secs, ext) 
     150 
     151            elif item == "JobCompletionTimeDate": 
     152                x = x.split(".")[0] 
    139153  
    140             resp += "<b>%s</b> = %s<br>" % (mapped_names[i], x.strip()) 
    141  
    142         file_items = ["FileSize"] 
    143         mapped_file_items = ["File Size (Bytes)"] 
    144  
     154            resp += "<b>%s</b> = %s<br>" % (mapped_names[i], x) 
     155 
     156        # Render output files if completed 
    145157        if self.status == "complete": 
    146158 
     
    164176                resp += ('<br><kbd>%s [<a href="%s">Download</a>]</kbd>' + (padding * "&nbsp;")) % (fname, furl) 
    165177 
    166                 for (i, file_item) in enumerate(file_items): 
    167                     x = fnode.find("{" + self.namespace +  "}" + file_item).text 
    168                     resp += '%s Bytes' % x 
     178                x = fnode.find("{" + self.namespace +  "}FileSize").text 
     179                x = self._toMB(x)  
     180                resp += x 
    169181 
    170182        return resp 
    171183 
     184    
     185    def _toMB(self, bytes, float_format = "%.2f"): 
     186        "Returns MB string from string or int or float." 
     187        mb = float_format % (int(bytes) / (2**20)) 
     188        if mb == "0.00": mb = "0.01" 
     189        mb += " MB" 
     190        return mb 
     191         
    172192 
    173193    def _htmlifyXML(self, xml): 
  • cows_wps/trunk/process_modules/extract_uk_station_data.py

    r7016 r7068  
    8181 
    8282        # Now check limit on number of station IDs 
    83         """ 
    84         n_src_ids = len(StationsIDs) 
    85         if n_src_ids > 100 and chunk_size == "decadal": 
     83        nStations = len(StationsIDs) 
     84        if nStations > 100 and TimeChunk == "decadal": 
    8685            raise Exception("The number of selected station IDs has been calculated to be greater than 100. Please select a chunk size other than 'decadal' for such as large volume of data.") 
    8786 
    88         N_YEARS = ? 
    89         if n_years > 1 and n_src_ids > 100: 
     87        nYears = int(EndDateTime[:4]) - int(StartDateTime[:4]) 
     88 
     89        if nYears > 1 and nStations > 100: 
    9090            raise Exception("The number of selected station IDs has been calculated to be greater than 100. Please select a time window no longer than 1 year.") 
    91         """ 
    9291 
    9392        self._addFileToFileSet(sf_path, "Station IDs file used for extraction of station data.", FLAG.DATA) 
  • cows_wps/trunk/process_modules/get_weather_stations.py

    r7066 r7068  
    4949        # Call standard _setup 
    5050        self._setup(context) 
     51        a = self.args 
    5152 
    5253        if not dry_run: 
     
    6061        if not dry_run: 
    6162            # Call code to get Weather Stations 
    62             a = self.args 
    6363            stationList = gws_utils.getStationList(a["Counties"], a["BBox"], a["DataTypes"],  
    6464                           a["StartDateTime"], a["EndDateTime"], stationsFilePath) 
     
    8282            self._addFileToOutputs(stationsFilePath, 'Weather Stations File') 
    8383        else: 
    84             estimated_size = 30000 
    85             self._addFileToOutputs(stationsFilePath, 'Weather Stations File', size = estimated_size) 
     84            # Estimate size of outputs by estimating the number of stations 
     85            if len(a["Counties"]) > 0: 
     86                nEstimatedStations = len(a["Counties"]) * 15 
     87            else: 
     88                (w, s, e, n) = a["BBox"] 
     89                lonExtent = abs(e - w) 
     90                latExtent = n - s 
     91                nEstimatedStations = int(lonExtent * latExtent * 50) 
     92 
     93            estimatedVolume = nEstimatedStations * 5 
     94            self._addFileToOutputs(stationsFilePath, 'Weather Stations File', size = estimatedVolume) 
    8695 
    8796        if not dry_run: 
     
    91100            process_support.finishProcess(context, self.fileSet, self.startTime, keep = True) 
    92101        else: 
    93             estimated_duration = 60 # seconds 
     102            estimated_duration = 10 # seconds 
    94103            process_support.finishDryRun(context, [], self.fileSet, 
    95104                            estimated_duration, acceptedMessage = 'Dry run complete')            
Note: See TracChangeset for help on using the changeset viewer.