Represents a two-dimensional ensemble-vs-time array of hwrf.hwrftask.HWRFTask objects.
Definition at line 33 of file ensda.py.
|
| def | __init__ (self, dstore, conf, section, anlintime=None, taskname=None, kwargs) |
| | Constructor for DAEnsemble. More...
|
| |
| def | anlintime (self) |
| | The time at the beginning of the first ensemble step. More...
|
| |
| def | anlouttime (self) |
| | The time at the end of the last ensemble step. More...
|
| |
| def | nmembers (self) |
| | The number of members of the ensemble. More...
|
| |
| def | nsteps (self) |
| | The number of ensemble DA time steps. More...
|
| |
| def | anlintimes (self) |
| | Iterates over all ensemble analysis input times. More...
|
| |
| def | anlouttimes (self) |
| | Iterates over all ensemble analysis output times. More...
|
| |
| def | member_ids (self) |
| | Iterates over all member ids. More...
|
| |
| def | set_member (self, atime, enkfmem, task) |
| | sets the HWRFTask to use to use for one cycle of one member More...
|
| |
| def | members_at_time (self, atime) |
| | iterate over members for a specified analysis input time More...
|
| |
| def | members_at_anlouttime (self) |
| | iterate over members at the final analysis output time. More...
|
| |
| def | steps_for_member (self, enkfmem) |
| | iterate over analysis cycles for a specific member More...
|
| |
| def | member (self, atime, enkfmem) |
| | get the analysis cycle for the specified member and time More...
|
| |
| def | inputiter (self) |
| | iterate over all needed input data, for hwrf.input More...
|
| |
| def | dump (self) |
| | print detailed diagnostics 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...
|
| |
Public Member Functions inherited from hwrf.hwrftask.HWRFTask
1.8.10
