Commit c92d7fa5 authored by Peters, Wouter's avatar Peters, Wouter
Browse files

extra filter to not copy all restart files each cycle

parent 8bc500fc
...@@ -341,7 +341,7 @@ class TM5ObservationOperator(ObservationOperator): ...@@ -341,7 +341,7 @@ class TM5ObservationOperator(ObservationOperator):
sourcedir = self.dacycle['dir.restart'] sourcedir = self.dacycle['dir.restart']
targetdir = self.tm_settings['restart.write.dir'] targetdir = self.tm_settings['restart.write.dir']
self.outputdir = self.tm_settings['output.dir'] #IV test filterlist = '%s' % self.da_cycle['time.sample.start']
for f in os.listdir(sourcedir): for f in os.listdir(sourcedir):
fpath = os.path.join(sourcedir, f) fpath = os.path.join(sourcedir, f)
...@@ -352,6 +352,9 @@ class TM5ObservationOperator(ObservationOperator): ...@@ -352,6 +352,9 @@ class TM5ObservationOperator(ObservationOperator):
if not f.startswith('TM5_restart'): if not f.startswith('TM5_restart'):
logging.debug(" [skip] .... %s " % fpath) logging.debug(" [skip] .... %s " % fpath)
continue continue
if not filterlist in f:
logging.debug(" [skip] .... %s " % fpath)
continue
# all okay, copy file # all okay, copy file
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment