------------------------------------------------------
lines 9-116 of file: at_cascade/csv/pre_one_process.py
------------------------------------------------------

{xrst_begin csv.pre_one_process}
{xrst_spell
  dtype
  numpy
}

Predict Using One Process
#########################
Keep predicting for as long as thee are jobs left to predict for.

Prototype
*********
{xrst_literal
    # BEGIN_DEF
    # END_DEF
}

fit_dir
*******
Same as the csv fit :ref:`csv.fit@fit_dir` .

sim_dir
*******
Same as :ref:`csv.predict@sim_dir` .

option_predict
**************
This is an in memory representation of
:ref:`csv.predict@Input Files@option_predict.csv` .

all_node_database
*****************
This is the all node database for this fit.

all_covariate_table
*******************
This is an in memory representation of
:ref:`csv.fit@Input Files@covariate.csv` .

job_table
*********
is the :ref:`create_job_table@job_table` for this cascade.

node_table
**********
is the dismod_at node table for this cascade.

root_node_id
************
is the node table id for the root node of the cascade.

root_split_reference_id
***********************
is the split_reference table id for the root job of the cascade

at_cascade_log_dict
*******************
For each :ref:`create_job_table@job_table@job_name` in the job table
that is a key in *at_cascade_log_dict*.  The corresponding value

| *at_cascade_log_dict* [ *job_name* ]


is a non-empty ``list`` of ``str`` containing ``at_cascade`` messages
in the log table for that job.
If a *job_name* is not a *key* is in *at_cascade_log_dict*,
there were no at_cascade messages for that job.

job_status_name
***************
is the name corresponding to each possible job status integer values.
If *i* is an integer job status value, *job_status_name* [ *i* ] is the
corresponding name.

.. csv-table::
    :header-rows: 1

    Name,    Meaning
    'skip',  job is not included in the predictions
    'ready', job is ready to run
    'run',   job is running
    'done',  job finished running

shared_job_status_name
**********************
This the name of the shared job status memory.
The corresponding multiprocessing shared memory is
a numpy array with ``dtype`` equal to ``int`` and
with length equal to the length of *job_table* .
The value *shared_job_status* [ *job_table_index* ] is the
integer status code for the corresponding job; see *job_status_name* above.

shared_lock
***********
This lock must be acquired during the time that
a process reads or changes *shared_job_status* .

Csv Output Files
****************
see :ref:`csv.pre_one_job@Csv Output Files`

Parallel Processing
*******************
Always copy ``dismod_at.db`` to another file before predicting with it
because ``dismod_at.db`` may be an ancestor for another prediction or fit
that is running in parallel.

{xrst_end csv.pre_one_process}