Skip to content
Snippets Groups Projects
Commit 39397186 authored by lkugler's avatar lkugler
Browse files

dont need arch scripts anymore

parent d4fa821c
No related branches found
No related tags found
No related merge requests found
import os, sys, warnings, glob
import datetime as dt
from cfg import exp, cluster
from utils import symlink, copy_scp_srvx8, copy, mkdir, mkdir_srvx8, clean_wrfdir
# if cluster.name != 'srvx8':
# copy = copy_scp_srvx8
# mkdir = mkdir_srvx8
time = dt.datetime.strptime(sys.argv[1], '%Y-%m-%d_%H:%M')
try:
print('archive obs space diagnostics')
savedir = cluster.archivedir+'/obs_seq_final/'
mkdir(savedir)
copy(cluster.dartrundir+'/obs_seq.final', savedir+time.strftime('/%Y-%m-%d_%H:%M_obs_seq.final'))
except Exception as e:
warnings.warn(str(e))
try:
print('archive regression diagnostics')
savedir = cluster.archivedir+'/reg_factor/'
mkdir(savedir)
copy(cluster.dartrundir+'/reg_diagnostics', savedir+time.strftime('/%Y-%m-%d_%H:%M_reg_diagnostics'))
except Exception as e:
warnings.warn(str(e))
print('archive model state')
try:
mkdir(cluster.archivedir)
print('copy prior posterior members to archive')
for iens in range(1, exp.n_ens+1):
savedir = cluster.archivedir+time.strftime('/%Y-%m-%d_%H:%M/')+str(iens)
mkdir(savedir)
copy(cluster.dartrundir+'/input.nml',
cluster.archivedir+time.strftime('/%Y-%m-%d_%H:%M/input.nml'))
filter_in = cluster.dartrundir+'/preassim_member_'+str(iens).zfill(4)+'.nc'
filter_out = cluster.dartrundir+'/filter_restart_d01.'+str(iens).zfill(4)
# files not necessary as wrfouts exist
#copy(filter_in, savedir+time.strftime('/%Y-%m-%d_%H:%M_prior'))
#copy(filter_out, savedir+time.strftime('/%Y-%m-%d_%H:%M_posterior'))
# copy mean and sd to archive
print('copy preassim, postassim mean and sd')
for f in ['preassim_mean.nc', 'preassim_sd.nc',
'output_mean.nc', 'output_sd.nc']:
copy(cluster.dartrundir+'/'+f,
cluster.archivedir+'/'+f[:-3]+time.strftime('_%Y-%m-%d_%H:%M:%S'))
except Exception as e:
warnings.warn(str(e))
import os, sys, warnings, glob
import datetime as dt
from config.cfg import exp, cluster
from utils import symlink, copy_scp_srvx8, copy, mkdir, mkdir_srvx8, clean_wrfdir
# if cluster.name != 'srvx8':
# copy = copy_scp_srvx8
# mkdir = mkdir_srvx8
time = dt.datetime.strptime(sys.argv[1], '%Y-%m-%d_%H:%M')
print('archive forecasts')
try:
start = time.strftime('%Y-%m-%d_%H:%M')
for iens in range(1, exp.n_ens+1):
savedir = cluster.archivedir()+'/'+start+'/'+str(iens)
mkdir(savedir)
wrfout_files = glob.glob(cluster.wrf_rundir(iens)+'/wrfout_d01_*')
wrfout_files.sort()
for f in wrfout_files:
copy(f, savedir+'/'+os.path.basename(f))
print(savedir+'/'+os.path.basename(f), 'saved.')
except Exception as e:
warnings.warn(str(e))
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment