Skip to content
Snippets Groups Projects
Select Git revision
  • c42a7869366fee829ae98ee9b7a703616aa53a15
  • master default protected
  • dev protected
  • replication_test
  • release-1.10 protected
  • release-1.9 protected
  • 551-init-broker-service-permissions
  • 549-test-oai-pmh
  • 545-saving-multiple-times-breaks-pid-metadata
  • 499-standalone-compute-service-2
  • 539-load-tests
  • hotfix/helm-chart
  • luca_ba_new_interface
  • 534-bug-when-adding-access-to-user-that-is-not-registered-at-dashboard-service
  • release-1.8 protected
  • 533-integrate-semantic-recommendation
  • feature/openshift
  • 518-spark-doesn-t-map-the-headers-correct
  • 485-fixity-checks
  • 530-various-schema-problems-with-subsets
  • release-1.7 protected
  • v1.10.2 protected
  • v1.10.1 protected
  • v1.10.0-rc13 protected
  • v1.10.0-rc12 protected
  • v1.10.0-rc11 protected
  • v1.10.0-rc10 protected
  • v1.10.0-rc9 protected
  • v1.10.0-rc8 protected
  • v1.10.0-rc7 protected
  • v1.10.0-rc6 protected
  • v1.10.0-rc5 protected
  • v1.10.0-rc4 protected
  • v1.10.0-rc3 protected
  • v1.10.0-rc2 protected
  • v1.10.0rc1 protected
  • v1.10.0rc0 protected
  • v1.10.0 protected
  • v1.9.3 protected
  • v1.9.2 protected
  • v1.9.2-rc0 protected
41 results

FdaDatabaseManagingApplication.java

Blame
  • evaluate_prior.py 1.41 KiB
    import os, sys, shutil, warnings
    import time as time_module
    import datetime as dt
    import numpy as np
    
    from dartwrf.exp_config import exp
    from dartwrf.server_config import cluster
    from dartwrf.utils import symlink, copy, sed_inplace, append_file, mkdir, try_remove, print, shell
    from dartwrf import assim_synth_obs as aso
    
    from osselyze.utils import get_prior_config
    
    if __name__ == "__main__":
    
         assim_time = dt.datetime.strptime(sys.argv[1], "%Y-%m-%d_%H:%M")
    
         print("> computing posterior observations ...")
         print(">> prepare prior ensemble")
         prior_exp, prior_init = get_prior_config(cluster.archive_base, exp.expname, init=assim_time)
         prior_valid_time = assim_time
         aso.prepare_prior_ensemble(assim_time, prior_init, prior_valid_time, cluster.archive_base+'/'+prior_exp)
    
        # prepare an obsseq without rejected observations
         if exp.use_existing_obsseq:  # from another exp
              oso_input = assim_time.strftime(exp.use_existing_obsseq)
         else:  # from same exp
              oso_input = cluster.archivedir+'/obs_seq_out' + assim_time.strftime("/%Y-%m-%d_%H:%M_obs_seq.out-beforeQC")
              if not os.path.isfile(oso_input):
                   oso_input = cluster.archivedir+'/obs_seq_out' + assim_time.strftime("/%Y-%m-%d_%H:%M_obs_seq.out")
              shutil.copy(oso_input, cluster.dart_rundir+'/obs_seq.out')
    
    
         aso.evaluate(assim_time, output_format="%Y-%m-%d_%H:%M_obs_seq.final-eval_prior_allobs")