HWRF
trunk@4391
|
runs a short WRF simulation to generate wrfanl files More...
runs a short WRF simulation to generate wrfanl files
Definition at line 1207 of file fcsttask.py.
Public Member Functions | |
def | make_wrf (self, wrf) |
creates the WRFSimulation object (self.wrf()) More... | |
def | anltime (self) |
the time for which analysis files are generated. More... | |
def | make_products (self) |
creates FileProduct objects for all wrfanl files. More... | |
def | get_wrfanl (self, domain) |
returns the wrfanl product for the specified domain More... | |
def | wrfanl_at_time (self, atime, domain) |
get a wrfanl file for a specified domain and analysis time More... | |
def | deliver_products (self) |
delivers products during a call to run() More... | |
def | products |
iterates over products Iterates over all Product objects that were identified by make_products. More... | |
![]() | |
def | __init__ (self, dstore, conf, section, wrf, keeprun=True, kwargs) |
constructor More... | |
def | make_wrf (self, wrf) |
creates a WRFSimulation object for this class More... | |
def | add_geogrid (self, g) |
adds a geogrid input source More... | |
def | add_metgrid (self, m) |
adds a metgrid input source More... | |
def | add_prep_hybrid (self, p) |
adds a prep_hybrid input source More... | |
def | use_prep_hybrid (self) |
returns True if prep_hybrid was requested, and False otherwise. More... | |
def | add_wrfinput (self, r) |
adds a wrfinput_d01 input source More... | |
def | add_wrfbdy (self, r) |
adds a wrfbdy_d01 input source More... | |
def | add_fort65 (self, r) |
adds a coupler fort.65 input source More... | |
def | add_real (self, r) |
add a fort.65, wrfinput_d01 and wrfbdy_d01 input source More... | |
def | add_wrfanl (self, r, domain) |
add a wrfanl input source for a specific domain More... | |
def | make_products (self) |
called from constructor, creates Products More... | |
def | link_fix (self) |
links or copies fixed data files More... | |
def | check_all_inputs (self) |
Checks to see if all needed input is available. More... | |
def | link_all_inputs |
Links all inputs provided by the various add_* member functions. More... | |
def | need_all_metgrid (self) |
Returns True if all metgrid files are needed as input to this Task. | |
def | run_exe |
runs the executable More... | |
def | final_prerun (self) |
last step before running executable More... | |
def | initial_prerun (self) |
called immediately after cding to a scrub directory More... | |
def | run (self) |
run the wrf or real_nmm More... | |
def | postrun (self) |
called just after run_exe() succeeds. More... | |
def | deliver_products (self) |
delivers products to their destinations More... | |
def | make_namelist |
generates the wrf namelist.input file More... | |
def | wrf (self) |
Returns the WRFSimulation object used by this task. More... | |
def | sim (self) |
Returns the WRFSimulation object used by this task. More... | |
![]() | |
def | __init__ (self, dstore, conf, section, outdir=None, taskname=None, kwargs) |
Creates a FcstTask object. More... | |
def | has_input (self, typename) |
is there any input data of this type to this task? More... | |
def | add_input (self, typename, inobj) |
add input of a specified type More... | |
def | check_input (self, typenames, kwargs) |
check if input data is available More... | |
def | link_input (self, typenames, just_check=False, kwargs) |
link or check for inputs More... | |
![]() | |
def | __init__ (self, dstore, conf, section, taskname=None, workdir=None, outdir=None, storminfo=UNSPECIFIED, taskvars=UNSPECIFIED, kwargs) |
Creates an HWRFTask. More... | |
def | isfakestorm (self) |
def | ismultistorm (self) |
def | get_workdir (self) |
Returns the directory the class should work in, as set by the "workdir" metadata value. More... | |
def | set_workdir (self, val) |
Sets the directory the class should work in. More... | |
def | get_outdir (self) |
Gets the directory that should receive output data. More... | |
def | set_outdir (self, val) |
Sets the directory that should receive output data. More... | |
def | realtime (self) |
Is this job a real-time forecast job? More... | |
def | redirect (self) |
Should subprograms' outputs be redirected to separate files? | |
def | scrub (self) |
Should temporary files be deleted as soon as they are not needed? | |
def | tvset (self, opt, val) |
Sets a taskvar option's value. More... | |
def | tvdel (self, opt) |
Deletes an object-local value set by tvset. More... | |
def | tvget (self, opt) |
Gets a taskvar's value. More... | |
def | tvhave |
Is a taskvar set? More... | |
def | taskvars (self) |
The dict of object-local values used for string substitution. More... | |
def | confint |
Alias for self.conf.getint for section self.section. More... | |
def | confstr |
Alias for self.conf.getstr for section self.section. More... | |
def | conffloat |
Alias for self.conf.getfloat for section self.section. More... | |
def | confbool |
Alias for self.conf.getbool for section self.section. More... | |
def | confget |
Alias for self.conf.get for section self.section. More... | |
def | confitems |
Alias for self.conf.items for section self.section. More... | |
def | confstrinterp (self, string, section=None, kwargs) |
Alias for self.icstr for backward compatibility. More... | |
def | conftimestrinterp (self, string, ftime, atime=None, section=None, kwargs) |
Alias for self.timestr for backward comaptibility. More... | |
def | confraw |
Get a raw configuration value before string expansion. More... | |
def | icstr (self, string, section=None, kwargs) |
Expands a string in the given conf section. More... | |
def | timestr (self, string, ftime, atime=None, section=None, kwargs) |
Expands a string in the given conf section, including time vars. More... | |
def | getdir |
Alias for hwrf.config.HWRFConfig.get() for the "dir" section. More... | |
def | getexe |
Alias for hwrf.config.HWRFConfig.get() for the "exe" section. More... | |
def | getconf (self) |
Returns this HWRFTask's hwrf.config.HWRFConfig object. More... | |
def | getsection (self) |
Returns this HWRFTask's section name in the HWRFConfig. More... | |
def | log |
Obtain a logging domain. More... | |
def | inputiter (self) |
Iterates over all inputs required by this task. More... | |
![]() | |
def | __init__ (self, dstore, taskname, logger=None, kwargs) |
Task constructor. More... | |
def | jlogfile (self) |
returns the jlogfile logger. More... | |
def | postmsg (self, message, args, kwargs) |
same as produtil.log.jlogger.info() More... | |
def | setstate (self, val) |
Sets the state of this job. More... | |
def | getstate (self) |
Returns the job state. More... | |
def | strstate (self) |
A string representation of the job state. More... | |
def | gettaskname (self) |
Returns the task name part of the database ID, which is the same as the prodname. More... | |
def | products (self, args, kwargs) |
Iterate over the products this task produces. More... | |
def | log (self) |
Returns the logger object for this task. More... | |
def | clean (self) |
Cleans up any unneeded data used by this task. More... | |
def | unrun (self) |
Undoes the effect of run(). More... | |
def | run (self) |
Performs the work this Task should do and generates all products. More... | |
def | is_completed (self) |
Is this task complete? More... | |
def | completed (self) |
Read-only property: is this task completed? Same as is_completed() More... | |
def | runpart (self) |
Run some of this task's work, deliver some products. More... | |
![]() | |
def | __init__ (self, dstore, prodname, category, meta=None, cache=30, location=None, kwargs) |
Datum constructor. More... | |
def | __enter__ (self) |
Acquires this object's thread lock. More... | |
def | __exit__ (self, etype, evalue, traceback) |
Releases this object's thread lock. More... | |
def | validate (self) |
Validates this object's Datastore, prodname and category. More... | |
def | getid (self) |
Returns the database ID of this datum. More... | |
def | getdatastore (self) |
Returns the datastore of this datum. More... | |
def | transaction (self) |
Creates, but does not lock, a Transaction for this datum's datastore. More... | |
def | getprodtype (self) |
Returns the product type of this Datum. More... | |
def | getprodname (self) |
Returns the product name part of the database ID. More... | |
def | getcategory (self) |
Returns the product category part of the database ID. More... | |
def | getlocation (self) |
Returns the "location" field of this Datum's database entry. More... | |
def | setlocation (self, v) |
Sets the "location" field of this Datum's database entry. More... | |
def | __hash__ (self) |
Integer hash function. More... | |
def | __str__ (self) |
Human-readable description of this Datum. More... | |
def | __repr__ (self) |
Python code-like description of this Datum. More... | |
def | __cmp__ (self, other) |
Compares two Datums' prodnames and categories. More... | |
def | set_loc_avail (self, loc, avail) |
Sets the location and availability of this Datum in a single transaction. More... | |
def | update (self) |
Discards all cached metadata and refreshes it from the Datastore. More... | |
def | __getitem__ (self, k) |
Returns the value of the specified metadata key or raises KeyError. More... | |
def | meta |
Return the value of a metadata key. More... | |
def | get |
Alias for self.meta() Returns the value of the specified metadata key or returns default if it is unset. More... | |
def | __setitem__ (self, k, v) |
Sets the value of the specified metadata key. More... | |
def | __delitem__ (self, k) |
Deletes the specified metadata key, which must not be "available" or "location". More... | |
def | __contains__ (self, k) |
Determines if a metadata key is set. More... | |
def | iteritems (self) |
Iterates over all metadata (key,value) pairs for this Datum, including "available" and "location". More... | |
Additional Inherited Members | |
![]() | |
dt_epsilon | |
epsilon value for time equality comparisons | |
keeprun | |
if False, temporary files are deleted, otherwise they're kept | |
location | |
![]() | |
inputs | |
a mapping of typename to a list of input objects | |
![]() | |
storminfo | |
The hwrf.storminfo.StormInfo describing the vitals information for the storm processed by this HWRFTask. More... | |
![]() | |
workdir | |
The directory in which this task should be run. More... | |
outdir | |
The directory in which this task should deliver its final output. More... | |
conf | |
This HWRFTask's hwrf.config.HWRFConfig object. More... | |
section | |
The confsection in self.section for this HWRFTask (read-only) More... | |
![]() | |
state | |
Read-write property: the job state. More... | |
taskname | |
Read-only property: the name of this task. More... | |
![]() | |
prodname = property(getprodname,None,None,) | |
Read-only property, an alias for getprodname(): the product name part of the database ID. More... | |
category = property(getcategory,None,None,) | |
Read-only property, an alias for getcategory(), the category name part of the database ID. More... | |
prodtype | |
Read-only property, an alias for getprodtype(), the product type. More... | |
did | |
Read-only property, an alias for getid(). More... | |
dstore | |
Read-only property, an alias for getdatastore(), the Datastore in which this Datum resides. More... | |
location | |
Read-write property, an alias for getlocation() and setlocation(). More... | |
def hwrf.fcsttask.WRFAnl.anltime | ( | self | ) |
the time for which analysis files are generated.
Definition at line 1237 of file fcsttask.py.
Referenced by hwrf.wrfbase.WRFOutput.__repr__(), hwrf.fcsttask.WRFAnl.wrfanl_at_time(), and hwrf.fcsttask.AnalysisCycle.wrfinput_at_time().
def hwrf.fcsttask.WRFAnl.deliver_products | ( | self | ) |
delivers products during a call to run()
Delivers the products (FileProduct objects) that were identified by make_products.
Definition at line 1270 of file fcsttask.py.
Referenced by hwrf.mpipomtc.POMInit.run(), hwrf.ww3.WW3Init.run(), hwrf.finalmergetask.FinalMergeTask.run(), hwrf.wps.Geogrid.run(), hwrf.gsi.GSIBase.run(), hwrf.wps.Ungrib.run(), hwrf.wps.Metgrid.run(), and hwrf.relocate.Merge.run().
def hwrf.fcsttask.WRFAnl.get_wrfanl | ( | self, | |
domain | |||
) |
returns the wrfanl product for the specified domain
domain | the domain for whom the wrfanl file is requested |
Definition at line 1250 of file fcsttask.py.
Referenced by hwrf.relocate.Stage3.wrfanl_at_time(), and hwrf.relocate.Merge.wrfanl_at_time().
def hwrf.fcsttask.WRFAnl.make_products | ( | self | ) |
creates FileProduct objects for all wrfanl files.
Definition at line 1240 of file fcsttask.py.
def hwrf.fcsttask.WRFAnl.make_wrf | ( | self, | |
wrf | |||
) |
creates the WRFSimulation object (self.wrf())
Creates a copy of the specified WRFSimulation wrf. The copy has a simulation length of one minute or one physics timestep, whichever is larger. Calls the _set_wrf_proc_config to set I/O server and compute grid dimensions based on this HWRFTask's config section. Configures the WRF to produce wrfanl files for all domains.
wrf | the wrf argument to init |
Definition at line 1209 of file fcsttask.py.
def hwrf.fcsttask.WRFAnl.products | ( | self, | |
domain = None |
|||
) |
iterates over products Iterates over all Product objects that were identified by make_products.
domain | if provided, only this domain's Products are yielded |
Definition at line 1286 of file fcsttask.py.
Referenced by hwrf.wrf.ExternalWRFTask.__init__(), hwrf.tracker.TrackerTask.call_completed_callbacks(), hwrf.wps.WPSTask.deliver_products(), hwrf.relocate.RelocationTask.deliver_products(), hwrf.wps.WPSTask.undeliver_products(), hwrf.prep.PrepHybrid.unrun(), hwrf.post.PostManyWRF.unrun(), hwrf.wrf.ExternalWRFTask.unrun(), and hwrf.wrf.ExternalWRFTask.wrf_check().
def hwrf.fcsttask.WRFAnl.wrfanl_at_time | ( | self, | |
atime, | |||
domain | |||
) |
get a wrfanl file for a specified domain and analysis time
Returns the wrfanl product for the specified domain and analysis time, if one exists, and otherwise, None.
domain | the domain (an integer, string name or WRFDomain) |
atime | the analysis time |
Definition at line 1258 of file fcsttask.py.