Changeset 65748f4 in flex_extract.git


Ignore:
Timestamp:
Sep 29, 2018, 9:36:59 PM (13 months ago)
Author:
Anne Philipp <anne.philipp@…>
Branches:
dev
Children:
27fe969
Parents:
295ff45
Message:

deleted unused variables, code style changes

File:
1 edited

Legend:

Unmodified
Added
Removed
  • source/python/classes/EcFlexpart.py

    r295ff45 r65748f4  
    492492        oro = False
    493493
    494         # define times
     494        # define times with datetime module
    495495        t12h = timedelta(hours=12)
    496496        t24h = timedelta(hours=24)
    497497
    498498        # dictionary which contains all parameter for the mars request
    499         # Entries with a "None" will change for different requests and therefore
    500         # will be set in each request seperately
     499        # entries with a "None" will change in different requests and will
     500        # therefore be set in each request seperately
    501501        retr_param_dict = {'marsclass':self.marsclass,
    502502                           'stream':None,
     
    518518
    519519        for ftype in self.types:
    520             # fk contains fields types such as
     520            # fk contains field types such as
    521521            #     [AN, FC, PF, CV]
    522522            # fv contains all of the items of the belonging key
     
    535535                retr_param_dict['date'] = self.dates
    536536                retr_param_dict['stream'] = self.stream
    537                 retr_param_dict['target'] = self.inputdir + "/" + ftype + \
    538                         pk + '.' + self.dates.split('/')[0] + '.' + \
    539                         str(os.getppid()) + '.' + str(os.getpid()) + ".grb"
     537                retr_param_dict['target'] = \
     538                    self._mk_targetname(ftype, pk,
     539                                        retr_param_dict['date'].split('/')[0])
    540540                retr_param_dict['param'] = pv[0]
    541541                retr_param_dict['levtype'] = pv[1]
     
    564564    # ------  on demand path  --------------------------------------------------
    565565                if not self.basetime:
     566                    # ******* start retrievement
    566567                    self._start_retrievement(request, retr_param_dict)
    567568    # ------  operational path  ------------------------------------------------
    568569                else:
    569570                    # check if mars job requests fields beyond basetime.
    570                     # If yes eliminate those fields since they may not
     571                    # if yes eliminate those fields since they may not
    571572                    # be accessible with user's credentials
    572                     if 'by' in retr_param_dict['step']:
    573                         sm1 = 2
    574                     else:
    575                         sm1 = -1
    576 
    577                     if 'by' in retr_param_dict['time']:
    578                         tm1 = 2
    579                     else:
    580                         tm1 = -1
    581 
    582                     maxdate = datetime.strptime(retr_param_dict['date'].split('/')[-1] +
    583                                                 retr_param_dict['time'].split('/')[tm1],
    584                                                 '%Y%m%d%H')
    585                     maxtime = maxdate + \
    586                         timedelta(hours=int(retr_param_dict['step'].split('/')[sm1]))
    587 
    588                     elimit = datetime.strptime(retr_param_dict['date'].split('/')[-1] +
    589                                                self.basetime, '%Y%m%d%H')
     573
     574                    enddate = retr_param_dict['date'].split('/')[-1]
     575                    elimit = datetime.strptime(enddate + self.basetime,
     576                                               '%Y%m%d%H')
    590577
    591578                    if self.basetime == '12':
     
    602589                            startdate = retr_param_dict['date'].split('/')[0]
    603590                            enddate = datetime.strftime(elimit - t24h,'%Y%m%d')
    604                             retr_param_dict['date'] = '/'.join([startdate, 'to', enddate])
    605 
     591                            retr_param_dict['date'] = '/'.join([startdate,
     592                                                                'to',
     593                                                                enddate])
     594
     595                            # ******* start retrievement
    606596                            self._start_retrievement(request, retr_param_dict)
    607597
     
    613603                                                    retr_param_dict['date'])
    614604
     605                            # ******* start retrievement
    615606                            self._start_retrievement(request, retr_param_dict)
    616607
    617608                        # --------------  non flux data ------------------------
    618609                        else:
     610                            # ******* start retrievement
    619611                            self._start_retrievement(request, retr_param_dict)
    620612
     
    638630                                retr_param_dict['time'] = times[0]
    639631
     632                        # ******* start retrievement
    640633                        self._start_retrievement(request, retr_param_dict)
    641634
     
    652645                                                    retr_param_dict['date'])
    653646
     647                            # ******* start retrievement
    654648                            self._start_retrievement(request, retr_param_dict)
    655649
Note: See TracChangeset for help on using the changeset viewer.
hosted by ZAMG