NEDAS.core package

Submodules

• NEDAS.core.assimilator module
  • Assimilator
    • Assimilator.assim_mode
    • Assimilator.assimilate()
    • Assimilator.partition_grid()
    • Assimilator.init_partitions()
    • Assimilator.assign_obs()
    • Assimilator.distribute_partitions()
    • Assimilator.transpose_to_ensemble_complete()
    • Assimilator.transpose_to_field_complete()
    • Assimilator.assimilation_algorithm()
• NEDAS.core.context module
  • Context
    • Context.comm
    • Context.comm_rec
    • Context.comm_mem
    • Context.progress
    • Context.grid
    • Context.grid_orig
    • Context.models
    • Context.datasets
    • Context.assimilator
    • Context.updator
    • Context.transform_funcs
    • Context.localization_funcs
    • Context.inflation_func
    • Context.state
    • Context.obs
    • Context.debug
    • Context.interactive
    • Context.is_notebook
    • Context.time
    • Context.iter
    • Context.pid_show
    • Context.nens
    • Context.mem_list
    • Context.fs
    • Context.io
    • Context.jsub
    • Context.check_interactive()
    • Context.check_notebook()
    • Context.get_cols()
    • Context.set_logging()
    • Context.distribute_mem_tasks()
    • Context.update_assim_tools()
    • Context.prev_time
    • Context.next_time
    • Context.set_comm()
    • Context.set_grid()
    • Context.set_models()
    • Context.set_datasets()
    • Context.total_tasks
    • Context.current_task
    • Context.message
    • Context.debug_message
    • Context.timer()
    • Context.logger()
    • Context.print_1p()
    • Context.log_event()
    • Context.show_greeting()
    • Context.show_summary()
    • Context.dump_config()
    • Context.run_job()
• NEDAS.core.dataset module
  • Dataset
    • Dataset.variables
    • Dataset.obs_operator
    • Dataset.memory
    • Dataset.dataset_name
    • Dataset.c
    • Dataset.parse_kwargs()
    • Dataset.get_mstr()
    • Dataset.get_tstr()
    • Dataset.generate_obs_network()
    • Dataset.read_obs()
    • Dataset.read_obs_from_file()
    • Dataset.read_obs_from_memory()
    • Dataset.write_obs()
    • Dataset.write_obs_to_file()
    • Dataset.write_obs_to_memory()
    • Dataset.save_memory()
    • Dataset.load_memory()
• NEDAS.core.diag module
  • Diagnostics
    • Diagnostics.task_list
    • Diagnostics.distribute_diag_tasks()
    • Diagnostics.init_file_locks()
• NEDAS.core.file_system module
  • FileSystem
    • FileSystem.config
    • FileSystem.cycle_dir()
    • FileSystem.forecast_dir()
    • FileSystem.analysis_dir()
    • FileSystem.make_dir()
    • FileSystem.copy_file()
    • FileSystem.move_file()
    • FileSystem.move_files_to_dir()
    • FileSystem.remove_files()
    • FileSystem.remove_dir()
    • FileSystem.link_file()
• NEDAS.core.inflation module
  • Inflation
    • Inflation.validate_obs_ens()
    • Inflation.obs_space_stats()
    • Inflation.adaptive_prior_inflation()
    • Inflation.adaptive_post_inflation()
    • Inflation.apply_inflation()
• NEDAS.core.io_backend module
  • IOBackend
    • IOBackend.io_mode
    • IOBackend.tags
    • IOBackend.validate_tag()
    • IOBackend.prepare_fields_storage()
    • IOBackend.read_field()
    • IOBackend.write_field()
    • IOBackend.call_method()
    • IOBackend.save_ndarray()
    • IOBackend.load_ndarray()
    • IOBackend.save_debug_data()
• NEDAS.core.job_submitter module
  • JobSubmitter
    • JobSubmitter.nproc
    • JobSubmitter.offset
    • JobSubmitter.nproc_avail
    • JobSubmitter.execute_command
    • JobSubmitter.parse_commands()
    • JobSubmitter.run()
• NEDAS.core.model module
  • Model
    • Model.variables
    • Model.grid
    • Model.z
    • Model.mask
    • Model.ens_init_dir
    • Model.truth_dir
    • Model.ens_run_strategy
    • Model.nproc_per_run
    • Model.nproc_per_util
    • Model.walltime
    • Model.run_process
    • Model.run_status
    • Model.restart_dir
    • Model.forecast_period
    • Model.memory
    • Model.io_mode
    • Model.model_name
    • Model.c
    • Model.parse_kwargs()
    • Model.get_mstr()
    • Model.get_tstr()
    • Model.read_grid()
    • Model.read_var()
    • Model.read_var_from_file()
    • Model.read_var_from_memory()
    • Model.write_var()
    • Model.write_var_to_file()
    • Model.write_var_to_memory()
    • Model.save_memory()
    • Model.load_memory()
    • Model.z_coords()
    • Model.preprocess()
    • Model.postprocess()
    • Model.run()
    • Model.generate_truth()
    • Model.generate_init_ensemble()
• NEDAS.core.obs module
  • Obs
    • Obs.obs_rec_list
    • Obs.obs_inds
    • Obs.obs_seq
    • Obs.obs_prior
    • Obs.lobs
    • Obs.lobs_prior
    • Obs.lobs_post
    • Obs.obs_post
    • Obs.data
    • Obs.distribute_obs_tasks()
    • Obs.get_ref_z()
    • Obs.state_to_obs()
    • Obs.get_model_fld_z_on_grid()
    • Obs.horizontal_interp()
    • Obs.vertical_interp()
    • Obs.validate_seq_shape()
    • Obs.collect_obs_seq()
    • Obs.prepare_obs()
    • Obs.prepare_obs_from_state()
    • Obs.global_obs_list()
    • Obs.transpose_obs_seq()
    • Obs.transpose_to_ensemble_complete()
    • Obs.transpose_to_field_complete()
    • Obs.pack_local_obs_data()
    • Obs.unpack_local_obs_data()
• NEDAS.core.obs_info module
  • ObsInfo
    • ObsInfo.records
    • ObsInfo.variables
    • ObsInfo.err_types
    • ObsInfo.add_obs_record()
    • ObsInfo.complete_err_cross_corr_matrix()
• NEDAS.core.perturb module
  • PerturbField
    • PerturbField.mask
    • PerturbField.perturb_type
    • PerturbField.other_opts
    • PerturbField.params
    • PerturbField.grid
    • PerturbField.perturb_methods
    • PerturbField.parse_perturb_opts()
    • PerturbField.generate_perturb()
    • PerturbField.add_perturb()
    • PerturbField.perturb_random_gaussian()
    • PerturbField.perturb_random_powerlaw()
    • PerturbField.perturb_random_displace()
    • PerturbField.make_correlated_perturb()
    • PerturbField.make_wind_perturb_from_press()
  • Perturbation
    • Perturbation.nfld
    • Perturbation.perturb
    • Perturbation.task_list
    • Perturbation.distribute_perturb_tasks()
    • Perturbation.count_num_fields()
    • Perturbation.prepare_perturb_dir()
    • Perturbation.save_perturb_data()
    • Perturbation.load_perturb_data()
    • Perturbation.collect_fields()
    • Perturbation.output_perturbed_fields()
• NEDAS.core.scheme module
  • Scheme
    • Scheme.steps_need_mpi
    • Scheme.scheduler
    • Scheme.config
    • Scheme.online_mode
    • Scheme.use_synthetic_obs
    • Scheme.c
    • Scheme.run_all()
    • Scheme.external_call()
    • Scheme.run_step()
    • Scheme.run_ensemble_tasks()
• NEDAS.core.state module
  • State
    • State.info
    • State.rec_list
    • State.partitions
    • State.par_list
    • State.fields_prior
    • State.fields_z
    • State.state_prior
    • State.state_z
    • State.state_post
    • State.fields_post
    • State.data
    • State.distribute_state_tasks()
    • State.prepare_state()
    • State.collect_prior_fields()
    • State.collect_scalar_variables()
    • State.output_state()
    • State.output_ens_mean()
    • State.output_ref_z()
    • State.pack_field_chunk()
    • State.unpack_field_chunk()
    • State.transpose_to_ensemble_complete()
    • State.transpose_to_field_complete()
    • State.pack_local_state_data()
    • State.unpack_local_state_data()
• NEDAS.core.state_info module
  • StateInfo
    • StateInfo.shape
    • StateInfo.mask
    • StateInfo.fields
    • StateInfo.size
    • StateInfo.variables
    • StateInfo.err_types
    • StateInfo.add_fields_for_variable()
    • StateInfo.write_to_file()
    • StateInfo.read_from_file()
• NEDAS.core.transform module
  • Transform
    • Transform.forward_state()
    • Transform.backward_state()
    • Transform.forward_obs()
    • Transform.backward_obs()
• NEDAS.core.types module
  • VarDesc
    • VarDesc.name
    • VarDesc.is_vector
    • VarDesc.dtype
    • VarDesc.dt
    • VarDesc.levels
    • VarDesc.units
    • VarDesc.z_units
    • VarDesc.asdict()
  • FieldRecord
    • FieldRecord.name
    • FieldRecord.model_src
    • FieldRecord.dtype
    • FieldRecord.is_vector
    • FieldRecord.units
    • FieldRecord.err_type
    • FieldRecord.time
    • FieldRecord.dt
    • FieldRecord.k
    • FieldRecord.pos
    • FieldRecord.asdict()
  • ErrorModel
    • ErrorModel.type
    • ErrorModel.std
    • ErrorModel.hcorr
    • ErrorModel.vcorr
    • ErrorModel.tcorr
    • ErrorModel.cross_corr
    • ErrorModel.asdict()
  • ObsRecord
    • ObsRecord.name
    • ObsRecord.dataset_src
    • ObsRecord.model_src
    • ObsRecord.nobs
    • ObsRecord.obs_window_min
    • ObsRecord.obs_window_max
    • ObsRecord.dtype
    • ObsRecord.is_vector
    • ObsRecord.units
    • ObsRecord.z_units
    • ObsRecord.time
    • ObsRecord.dt
    • ObsRecord.err
    • ObsRecord.hroi
    • ObsRecord.vroi
    • ObsRecord.troi
    • ObsRecord.impact_on_state
    • ObsRecord.asdict()
• NEDAS.core.updator module
  • Updator
    • Updator.increment
    • Updator.update()
    • Updator.init_all_file_locks()
    • Updator.compute_increment()
    • Updator.update_files()