|
HWRF
trunk@4391
|
This is a HWRF task that forms the base class for all vortex relocation tasks, including the Merge. More...
This is a HWRF task that forms the base class for all vortex relocation tasks, including the Merge.
It exists solely to reduce code complexity.
Definition at line 207 of file relocate.py.
Public Member Functions | |
| def | __init__ (self, dstore, conf, section, sim, domains, taskname=None, modin='GDAS1', wrfanl=None, wrfghost=None, wrfinput=None, parentTrack=None, trackName='track0', ghost_domains=None, dest_dir=None, gsi_d02=None, gsi_d03=None, gsi_d01=None, cycling_interval=-6 *3600, info=None, fgat_times=None, centrack=None, ensda=None, kwargs) |
| RelocationTask constructor. More... | |
| def | get_wrfinput |
| Returns the wrfinput output Product for the specified domain, or None if no such domain is known. More... | |
| def | get_wrfanl (self, domain) |
| Returns the wrfanl output Product for this Task for the specified domain or None if no such product exists. More... | |
| def | get_ghost (self, domain) |
| Returns the wrfghost output Product for this Task for the specified domain. More... | |
| def | wrfinput_at_time (self, atime, domain) |
| Returns the wrfinput output file for the specified time and domain, or returns None if no such file exists. More... | |
| def | wrfanl_at_time (self, atime, domain) |
| Returns the wrfanl output file for the specified time and domain, or None if no such file exists. More... | |
| def | copy_fixed (self) |
| Copies the fixed files to the local directory. More... | |
| def | delete_temp (self) |
| Deletes all temporary files created by the relocation jobs. More... | |
| def | products (self) |
| Iterates over all products generated by this task. More... | |
| def | deliver_products (self, missing=None, logger=None, keep=False, frominfo=None, kwargs) |
| Delivers products to intercom via Product.deliver. More... | |
| def | write_vitals |
| Writes the tcvitals (from self.storminfo) to the specified file. More... | |
| def | make_ghost_namelist |
| Writes the ghost namelist to namelist_ghost.input. More... | |
| def | make_analysis_namelist |
| Writes the analysis namelist to namelist_analysis.input. More... | |
| def | parent_track (self) |
| The Product object for the parent track file. More... | |
| def | modin (self) |
| The DA mode. More... | |
| def | vortex (self) |
| The vortex origin status. More... | |
| def | warm (self) |
| The status of the current cycle. More... | |
| def | prev_cycle_dir (self) |
| The previous cycle's COM directory. More... | |
| def | prev_cycle_sid (self) |
| def | storm_intensity (self) |
| The storm intensity. More... | |
| def | storm_basin (self) |
| The storm basin. More... | |
| def | center_lat (self) |
| The domain center latitude. More... | |
| def | center_lon (self) |
| The domain center longitude. More... | |
| def | storm_id (self) |
| The storm ID. More... | |
| def | fhr (self) |
| The forecast hour. More... | |
| def | rinfo (self) |
| The RelocationInfo. More... | |
| def | copy_inputs (self) |
| Copies, or makes, one or more input files. More... | |
| def | set_ensda (self, ensda) |
| def | get_centrack (self) |
| Returns the Product for the center FGAT time track file if available, or otherwise the parent track file Product. More... | |
| def | set_centrack (self, centrack) |
| Sets the Product for the center FGAT time track file. More... | |
| def | del_centrack (self) |
| Unsets the center FGAT time track file so that get_centrack() will return the parent track file instead. More... | |
| def | create_atcf (self, case) |
| Gets the parent vortex track file, either from a specified directory or from the tracker, run by a previous hwrf.init.HWRFInit object's tracker member. More... | |
| def | run_ext |
| Helper function for running Fortran programs that need fort. More... | |
 Public Member Functions inherited from hwrf.hwrftask.HWRFTask | |
| 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... | |
| Public Member Functions inherited from produtil.datastore.Task | |
| 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... | |
| Public Member Functions inherited from produtil.datastore.Datum | |
| 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 Attributes | |
| info | |
| A RelocationInfo object to trade relocation information with other stages of the relocation. More... | |
| fgat_times | |
| The list of FGAT hours. More... | |
| cycling_interval | |
| The positive datetime.timedelta time between cycles. More... | |
| sim | |
| The hwrf.wrf.WRFSimulation describing the WRF simulation. | |
| domains | |
| The list of domains from sim that match the domains with the same name provided to the constructor. More... | |
| dt_epsilon | |
| An epsilon value for time equality comparisons. | |
| ghost_domains | |
| The list of ghost domains passed to the constructor. More... | |
| dest_dir | |
| Delivery directory for outputs. More... | |
| modin | |
| The input model: GFS or GDAS1. | |
| Public Attributes inherited from hwrf.hwrftask.HWRFTask | |
| storminfo | |
| The hwrf.storminfo.StormInfo describing the vitals information for the storm processed by this HWRFTask. More... | |
Properties | |
| centrack | |
| The track file for the center FGAT hour. More... | |
| Properties inherited from hwrf.hwrftask.HWRFTask | |
| 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... | |
| Properties inherited from produtil.datastore.Task | |
| state | |
| Read-write property: the job state. More... | |
| taskname | |
| Read-only property: the name of this task. More... | |
| Properties inherited from produtil.datastore.Datum | |
| 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.relocate.RelocationTask.__init__ | ( | self, | |
| dstore, | |||
| conf, | |||
| section, | |||
| sim, | |||
| domains, | |||
taskname = None, |
|||
modin = 'GDAS1', |
|||
wrfanl = None, |
|||
wrfghost = None, |
|||
wrfinput = None, |
|||
parentTrack = None, |
|||
trackName = 'track0', |
|||
ghost_domains = None, |
|||
dest_dir = None, |
|||
gsi_d02 = None, |
|||
gsi_d03 = None, |
|||
gsi_d01 = None, |
|||
cycling_interval = -6*3600, |
|||
info = None, |
|||
fgat_times = None, |
|||
centrack = None, |
|||
ensda = None, |
|||
| kwargs | |||
| ) |
RelocationTask constructor.
| dstore | the produtil.datastore.Datastore for database storage |
| conf | the hwrf.config.HWRFConfig for configuration info |
| section | the configuration section to use |
| sim | the hwrf.wrf.WRFSimulation describing the simulation being relocated |
| domains | the hwrf.wrf.WRFDomains being relocated |
| taskname | the taskname in the database |
| modin | input model: "GFS" or "GDAS1". |
| wrfanl | the wrfanl input source, which should have a get_wrfanl() function that accepts an hwrf.wrf.WRFDomain and returns an hwrf.datastore.Product |
| wrfghost | the ghost file input source, which should have a get_ghost() function that accepts an hwrf.wrf.WRFDomain and returns an hwrf.datastore.Product |
| wrfinput | the wrfinput datasource, which must have a get_wrfinput() function that returns an hwrf.datastore.Product for the wrfinput file |
| parentTrack | the parent track file input source, which must have a products() function that takes the track product name and returns the produtil.datastore.Product |
| trackName | the parent track name to pass to parentTrack.products() |
| ghost_domains | the list of ghost domains for relocation input |
| dest_dir | output directory for the relocation |
| gsi_d02 | the hwrf.gsi.FGATGSI that will run the GSI for the intermediate domain. |
| gsi_d03 | the hwrf.gsi.FGATGSI that will run the GSI for the innermost domain. |
| gsi_d01 | the hwrf.gsi.GSIBase that will run GSI for the outermost domain. |
| cycling_interval | negative number of seconds between cycles (-6*3600) |
| info | the RelocationInfo object to use |
| fgat_times | the list of FGAT times, datetime.datetime objects |
| centrack | the product for the center FGAT time track |
| kwargs | passed to hwrf.hwrftask.HWRFTask.__init__ |
Definition at line 216 of file relocate.py.
| def hwrf.relocate.RelocationTask.center_lat | ( | self | ) |
The domain center latitude.
Definition at line 614 of file relocate.py.
Referenced by hwrf.relocate.Stage1.merge_nest(), and hwrf.relocate.Stage2.merge_nests().
| def hwrf.relocate.RelocationTask.center_lon | ( | self | ) |
The domain center longitude.
Definition at line 619 of file relocate.py.
Referenced by hwrf.relocate.Stage1.merge_nest(), and hwrf.relocate.Stage2.merge_nests().
| def hwrf.relocate.RelocationTask.copy_fixed | ( | self | ) |
Copies the fixed files to the local directory.
Definition at line 453 of file relocate.py.
Referenced by hwrf.relocate.Stage1.run(), hwrf.relocate.Stage2.run(), and hwrf.relocate.Stage3.run().
| def hwrf.relocate.RelocationTask.copy_inputs | ( | self | ) |
Copies, or makes, one or more input files.
Definition at line 674 of file relocate.py.
Referenced by hwrf.relocate.Stage2.run(), and hwrf.relocate.Merge.run().
| def hwrf.relocate.RelocationTask.create_atcf | ( | self, | |
| case | |||
| ) |
Gets the parent vortex track file, either from a specified directory or from the tracker, run by a previous hwrf.init.HWRFInit object's tracker member.
| case | 1 or 2: 1 for creating the atcfunix file, 2 for the atcfunix_cen file. |
Definition at line 722 of file relocate.py.
Referenced by hwrf.relocate.Stage1.run(), hwrf.relocate.Stage2.run(), and hwrf.relocate.Stage3.weak_cold_run().
| def hwrf.relocate.RelocationTask.del_centrack | ( | self | ) |
Unsets the center FGAT time track file so that get_centrack() will return the parent track file instead.
Definition at line 712 of file relocate.py.
| def hwrf.relocate.RelocationTask.delete_temp | ( | self | ) |
Deletes all temporary files created by the relocation jobs.
Definition at line 464 of file relocate.py.
Referenced by hwrf.relocate.Stage1.run().
| def hwrf.relocate.RelocationTask.deliver_products | ( | self, | |
missing = None, |
|||
logger = None, |
|||
keep = False, |
|||
frominfo = None, |
|||
| kwargs | |||
| ) |
Delivers products to intercom via Product.deliver.
Any keyword arguments are passed on to Product.deliver. By default, keep=False, which means the local copy of the file may no longer exists. If frominfo is specified, it will be ignored.
| keep | If True, then the file may be moved to the destination instead of copying. |
| frominfo | Ignored. |
| kwargs | Passed to produtil.datastore.FileProduct.deliver() |
| logger | a logging.Logger for log messages |
| missing | a function called if the file to deliver does not exist. It is passed the product and the basename of the file. |
Definition at line 501 of file relocate.py.
Referenced by hwrf.relocate.RelocationTask.products(), hwrf.ww3.WW3Init.run(), hwrf.wps.Geogrid.run(), hwrf.wps.Ungrib.run(), hwrf.wps.Metgrid.run(), and hwrf.relocate.Merge.run().
| def hwrf.relocate.RelocationTask.fhr | ( | self | ) |
The forecast hour.
Definition at line 629 of file relocate.py.
Referenced by hwrf.relocate.Stage3.anl_4x(), hwrf.relocate.Stage1.split_wrf(), and hwrf.relocate.Stage2.wrf_split().
| def hwrf.relocate.RelocationTask.get_centrack | ( | self | ) |
Returns the Product for the center FGAT time track file if available, or otherwise the parent track file Product.
Definition at line 697 of file relocate.py.
| def hwrf.relocate.RelocationTask.get_ghost | ( | self, | |
| domain | |||
| ) |
Returns the wrfghost output Product for this Task for the specified domain.
| domain | the domain of interest |
Definition at line 419 of file relocate.py.
| def hwrf.relocate.RelocationTask.get_wrfanl | ( | self, | |
| domain | |||
| ) |
Returns the wrfanl output Product for this Task for the specified domain or None if no such product exists.
| domain | the domain of interest |
Definition at line 411 of file relocate.py.
Referenced by hwrf.relocate.Stage3.wrfanl_at_time(), and hwrf.relocate.Merge.wrfanl_at_time().
| def hwrf.relocate.RelocationTask.get_wrfinput | ( | self, | |
domain = None |
|||
| ) |
Returns the wrfinput output Product for the specified domain, or None if no such domain is known.
| domain | the domain of interest |
Definition at line 378 of file relocate.py.
Referenced by hwrf.relocate.RelocationTask.wrfinput_at_time(), and hwrf.relocate.Stage3.wrfinput_at_time().
| def hwrf.relocate.RelocationTask.make_analysis_namelist | ( | self, | |
| filename, | |||
logger = None |
|||
| ) |
Writes the analysis namelist to namelist_analysis.input.
Note that this overwrites, and then deletes, namelist.input and fort.12. It will also create the domain.center and storm.center files and fill them with correct locations.
| filename | the file to write |
| logger | a logging.Logger for log messages |
Definition at line 555 of file relocate.py.
Referenced by hwrf.relocate.Stage1.copy_namelist().
| def hwrf.relocate.RelocationTask.make_ghost_namelist | ( | self, | |
| filename, | |||
logger = None |
|||
| ) |
Writes the ghost namelist to namelist_ghost.input.
Note that this overwrites, and then deletes, namelist.input and fort.12. It will also create the domain.center and storm.center files and fill them with correct locations.
| filename | the file to write |
| logger | a logging.Logger for log messages |
Definition at line 540 of file relocate.py.
Referenced by hwrf.relocate.Stage1.copy_namelist().
| def hwrf.relocate.RelocationTask.modin | ( | self | ) |
The DA mode.
Definition at line 579 of file relocate.py.
| def hwrf.relocate.RelocationTask.parent_track | ( | self | ) |
The Product object for the parent track file.
Definition at line 571 of file relocate.py.
Referenced by hwrf.relocate.RelocationTask.create_atcf(), hwrf.relocate.RelocationTask.get_centrack(), and hwrf.relocate.Stage3.get_track().
| def hwrf.relocate.RelocationTask.prev_cycle_dir | ( | self | ) |
The previous cycle's COM directory.
Definition at line 596 of file relocate.py.
Referenced by hwrf.relocate.Stage1.check_prior_cycle(), hwrf.relocate.Stage1.copy_hdas(), and hwrf.relocate.Stage1.relocate_storm().
| def hwrf.relocate.RelocationTask.products | ( | self | ) |
Iterates over all products generated by this task.
Definition at line 495 of file relocate.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.wrf.ExternalWRFTask.unrun(), and hwrf.wrf.ExternalWRFTask.wrf_check().
| def hwrf.relocate.RelocationTask.rinfo | ( | self | ) |
The RelocationInfo.
Definition at line 634 of file relocate.py.
| def hwrf.relocate.RelocationTask.run_ext | ( | self, | |
| cmd, | |||
echo = None, |
|||
inputs = None, |
|||
incopies = None, |
|||
outputs = None, |
|||
opt_outputs = None |
|||
| ) |
Helper function for running Fortran programs that need fort.
Run an external command linking in fort.X files for input and output. If self.redirect=True, redirect logs to a separate file.
| cmd | The command to execute. This function will use "self.getexe()" on the command to find the external program to execute. |
| echo | If a list is passed in as the echo variable, then the contents will be sent to the stdin of the program as a string. |
| inputs | Input dictionary for files to link. See below. |
| incopies | Input dictionary for files to copy. See below. |
| outputs | Output dictionary for files to link. See below. If the output is not present, a message is logged at ERROR level. |
| opt_outputs | Optional outputs dictionary for files to link. See below. If the outputs are not present, it is not considered an error. |
The dictionary arguments should consist of a fortran file number and the source file.
would produce symbolic links:
input files can also be copied using incopies:
would create files instead of links.
The outputs and opt_outputs (optional outputs) should be of the dictionary as the inputs. As in: outputs = {56:new_data_4x, 85:storm_radius} this would mean the "fort.56" file would be renamed to "new_data_4x" and the "fort.85" renamed to "storm_radius".
If opt_outputs is given then the fortran file is tested to see if it exists and only if it does is it renamed to the output filename.
A log file will be created consisting of the stdout and stderr of the command run. It will be named consisting of the taskname and command. For example, if this is relocation stage 1 and the command is hwrf_pert_ct then the log file is "rel_stage_1_hwrf_pert_ct.log"
Definition at line 778 of file relocate.py.
Referenced by hwrf.relocate.Stage3.anl_4x(), hwrf.relocate.Stage3.anl_bogus_10m(), hwrf.relocate.Stage3.anl_cs_10m(), hwrf.relocate.Merge.blend_gsi(), hwrf.relocate.RelocationTask.create_atcf(), hwrf.relocate.Stage2.create_nest(), hwrf.relocate.Stage2.create_track(), hwrf.relocate.Stage3.create_track(), hwrf.relocate.Stage1.guess_track(), hwrf.relocate.Merge.inter_2to1(), hwrf.relocate.Merge.inter_2to1ges(), hwrf.relocate.Stage3.inter_2to2(), hwrf.relocate.Merge.inter_2to2(), hwrf.relocate.Stage3.inter_2to2_again(), hwrf.relocate.Merge.inter_2to3(), hwrf.relocate.Merge.inter_2to6(), hwrf.relocate.Merge.inter_3to2(), hwrf.relocate.Stage3.inter_4to6(), hwrf.relocate.Stage1.merge_nest(), hwrf.relocate.Stage2.merge_nests(), hwrf.relocate.Stage1.pert_ct(), hwrf.relocate.Stage3.pert_ct_gfs(), hwrf.relocate.Stage3.pert_ct_weak(), hwrf.relocate.Stage1.split_wrf(), and hwrf.relocate.Stage2.wrf_split().
| def hwrf.relocate.RelocationTask.set_centrack | ( | self, | |
| centrack | |||
| ) |
Sets the Product for the center FGAT time track file.
| centrack | the center FGAT track product |
Definition at line 704 of file relocate.py.
| def hwrf.relocate.RelocationTask.storm_basin | ( | self | ) |
The storm basin.
Definition at line 609 of file relocate.py.
Referenced by hwrf.relocate.Stage3.anl_4x(), hwrf.relocate.Stage3.anl_bogus_10m(), hwrf.relocate.Stage3.anl_cs_10m(), hwrf.relocate.Merge.blend_gsi(), hwrf.relocate.Stage2.create_nest(), hwrf.relocate.Stage2.create_track(), hwrf.relocate.Stage3.create_track(), hwrf.relocate.Merge.inter_2to1(), hwrf.relocate.Merge.inter_2to1ges(), hwrf.relocate.Stage3.inter_4to6(), hwrf.relocate.Stage2.merge_nests(), hwrf.relocate.Stage1.pert_ct(), hwrf.relocate.Stage3.pert_ct_gfs(), hwrf.relocate.Stage3.pert_ct_weak(), hwrf.relocate.Stage1.split_wrf(), and hwrf.relocate.Stage2.wrf_split().
| def hwrf.relocate.RelocationTask.storm_id | ( | self | ) |
The storm ID.
Definition at line 624 of file relocate.py.
Referenced by hwrf.relocate.Stage2.create_track(), hwrf.relocate.Stage3.create_track(), and hwrf.relocate.Stage1.guess_track().
| def hwrf.relocate.RelocationTask.storm_intensity | ( | self | ) |
The storm intensity.
Definition at line 604 of file relocate.py.
Referenced by hwrf.relocate.Stage1.copy_hdas(), hwrf.relocate.Stage1.merge_nest(), hwrf.relocate.Stage1.split_wrf(), and hwrf.relocate.Stage2.wrf_split().
| def hwrf.relocate.RelocationTask.vortex | ( | self | ) |
The vortex origin status.
Definition at line 584 of file relocate.py.
| def hwrf.relocate.RelocationTask.warm | ( | self | ) |
The status of the current cycle.
True if it is a cycled run. False if it is a cold start.
Definition at line 589 of file relocate.py.
| def hwrf.relocate.RelocationTask.wrfanl_at_time | ( | self, | |
| atime, | |||
| domain | |||
| ) |
Returns the wrfanl output file for the specified time and domain, or None if no such file exists.
| atime | the time of interest |
| domain | the domain of interest |
Definition at line 440 of file relocate.py.
| def hwrf.relocate.RelocationTask.wrfinput_at_time | ( | self, | |
| atime, | |||
| domain | |||
| ) |
Returns the wrfinput output file for the specified time and domain, or returns None if no such file exists.
| atime | the time of interest |
| domain | the domain of interest |
Definition at line 426 of file relocate.py.
| def hwrf.relocate.RelocationTask.write_vitals | ( | self, | |
filename = 'tcvitals.as', |
|||
logger = None |
|||
| ) |
Writes the tcvitals (from self.storminfo) to the specified file.
| filename | the file to write |
| logger | a logging.Logger for log messages |
Definition at line 529 of file relocate.py.
Referenced by hwrf.relocate.RelocationTask.copy_inputs(), hwrf.relocate.Stage1.run(), and hwrf.relocate.Stage2.run().
| hwrf.relocate.RelocationTask.cycling_interval |
The positive datetime.timedelta time between cycles.
Definition at line 259 of file relocate.py.
Referenced by hwrf.relocate.Stage1.check_atcf_hours(), and hwrf.relocate.Stage1.copy_hdas().
| hwrf.relocate.RelocationTask.dest_dir |
Delivery directory for outputs.
Definition at line 340 of file relocate.py.
Referenced by hwrf.relocate.Merge.blend_gsi(), hwrf.relocate.RelocationTask.delete_temp(), hwrf.relocate.Stage1.relocate_storm(), hwrf.relocate.Stage2.relocate_storm(), hwrf.relocate.Merge.relocate_storm(), hwrf.relocate.Stage1.run(), hwrf.relocate.Stage2.run(), hwrf.relocate.Stage3.run(), hwrf.relocate.Merge.run(), hwrf.relocate.RelocationTask.run_ext(), hwrf.relocate.Stage3.update_3dvar(), and hwrf.relocate.Merge.update_3dvar().
| hwrf.relocate.RelocationTask.domains |
The list of domains from sim that match the domains with the same name provided to the constructor.
Definition at line 280 of file relocate.py.
Referenced by hwrf.post.PostManyWRF.__init__(), hwrf.relocate.Stage1.check_prior_cycle(), hwrf.wps.WPSTask.deliver_products(), hwrf.relocate.Stage3.get_ghost(), hwrf.relocate.Stage3.get_wrfanl(), hwrf.relocate.Merge.get_wrfanl(), hwrf.relocate.Stage3.get_wrfinput(), hwrf.relocate.Merge.get_wrfinput(), hwrf.wps.Geogrid.make_products(), hwrf.relocate.Stage3.products(), hwrf.relocate.Merge.products(), hwrf.relocate.Stage1.relocate_storm(), hwrf.relocate.Stage2.relocate_storm(), hwrf.relocate.Merge.relocate_storm(), hwrf.relocate.Stage3.update_3dvar(), and hwrf.relocate.Merge.update_3dvar().
| hwrf.relocate.RelocationTask.fgat_times |
The list of FGAT hours.
Definition at line 253 of file relocate.py.
Referenced by hwrf.relocate.Stage1.check_atcf_hours(), hwrf.relocate.Stage1.check_prior_cycle(), and hwrf.init.HWRFInit.fgat_times().
| hwrf.relocate.RelocationTask.ghost_domains |
The list of ghost domains passed to the constructor.
Definition at line 317 of file relocate.py.
Referenced by hwrf.relocate.Stage3.get_ghost(), and hwrf.relocate.Stage3.products().
| hwrf.relocate.RelocationTask.info |
A RelocationInfo object to trade relocation information with other stages of the relocation.
Definition at line 249 of file relocate.py.
Referenced by hwrf.relocate.Stage3.anl_4x(), hwrf.relocate.Stage3.anl_bogus_10m(), hwrf.relocate.Stage3.anl_cs_10m(), hwrf.relocate.Stage1.copy_namelist(), hwrf.relocate.Stage2.create_track(), hwrf.relocate.Stage3.cycled_or_weak_run(), hwrf.relocate.Stage3.ensda_relocate_run(), hwrf.relocate.Stage1.guess_track(), hwrf.relocate.Merge.inter_2to1(), hwrf.relocate.Merge.inter_2to1ges(), hwrf.relocate.Stage3.inter_2to2(), hwrf.relocate.Merge.inter_2to2(), hwrf.relocate.Stage3.inter_2to2_again(), hwrf.relocate.Merge.inter_2to3(), hwrf.relocate.Merge.inter_2to6(), hwrf.relocate.Merge.inter_3to2(), hwrf.relocate.Stage3.inter_4to6(), hwrf.relocate.Stage1.merge_nest(), hwrf.relocate.Stage2.merge_nests(), hwrf.relocate.Stage1.pert_ct(), hwrf.relocate.Stage3.pert_ct_gfs(), hwrf.relocate.Stage3.pert_ct_weak(), hwrf.relocate.Stage1.relocate_storm(), hwrf.relocate.Stage2.relocate_storm(), hwrf.relocate.RelocationTask.rinfo(), hwrf.relocate.Stage1.split_wrf(), hwrf.relocate.Stage3.update_3dvar(), hwrf.relocate.Merge.update_3dvar(), hwrf.relocate.Stage3.weak_cold_run(), hwrf.relocate.Stage2.wrf_split(), hwrf.relocate.RelocationTask.wrfanl_at_time(), hwrf.relocate.Stage3.wrfanl_at_time(), hwrf.relocate.RelocationTask.wrfinput_at_time(), and hwrf.relocate.Stage3.wrfinput_at_time().
|
static |
The track file for the center FGAT hour.
Definition at line 719 of file relocate.py.
Referenced by hwrf.relocate.RelocationTask.create_atcf().
1.8.10
