Package saga :: Package cpr :: Module _cpr :: Class job

Class job

 object --+                
          |                
??.instance --+            
              |            
 _engine.object --+        
                  |        
       _engine.task --+    
                      |    
           job._job.job --+
                          |
                         job

Known Subclasses:

self

Nested Classes

[hide private]

Inherited from _engine.task: routine_type, task_state

Inherited from _engine.object: object_type

Instance Methods

[hide private]

checkpoint(...)
checkpoint( (job)arg1 [, (url)arg2]) -> None : checkpoint a job (plain)

cpr_last(...)
cpr_last( (job)arg1) -> url : get last known checkpoint (plain)

cpr_list(...)
cpr_list( (job)arg1) -> object : get list of known checkpoints (plain)

cpr_stage_in(...)
cpr_stage_in( (job)arg1 [, (url)arg2]) -> None : stage-in a checpoint file (plain)

cpr_stage_out(...)
cpr_stage_out( (job)arg1 [, (url)arg2]) -> None : stage-out a checpoint file (plain)

recover(...)
recover( (job)arg1 [, (url)arg2]) -> None : recover a job (plain)

Inherited from job._job.job: __init__, attribute_exists, attribute_is_readonly, attribute_is_removable, attribute_is_vector, attribute_is_writable, find_attributes, get_attribute, get_description, get_job_id, get_state, get_vector_attribute, list_attributes, migrate, remove_attribute, resume, set_attribute, set_vector_attribute, signal, suspend

Inherited from _engine.task: add_callback, cancel, get_metric, get_object, get_result, list_metrics, remove_callback, rethrow, run, wait

Inherited from _engine.object: __reduce__, clone, get_id, get_object_type_name, get_session, get_type

Inherited from unreachable.instance: __new__

Inherited from object: __delattr__, __getattribute__, __hash__, __reduce_ex__, __repr__, __setattr__, __str__

Class Variables

[hide private]

Inherited from _engine.task: ASync, Canceled, Done, Failed, New, Running, Sync, Task, Unknown

Inherited from _engine.object: Advert, AdvertDirectory, Buffer, Context, Directory, Endpoint, Exception, File, IOVec, Job, JobDescription, JobSelf, JobService, LogicalDirectory, LogicalFile, Metric, Msg, NSDirectory, NSEntry, Parameter, RPC, Session, Stream, StreamService, TaskContainer, URL, __instance_size__

Properties

[hide private]

Inherited from _engine.task: object, state

Inherited from _engine.object: id, session, type

Inherited from object: __class__

Method Details

[hide private]

checkpoint(...)


checkpoint( (job)arg1 [, (url)arg2]) -> None :
    checkpoint a job (plain)

    C++ signature :
        void checkpoint(saga::cpr::job [,saga::url])

checkpoint( (job)arg1, (routine_type)arg2 [, (url)arg3]) -> task :
    checkpoint a job (task based)

    C++ signature :
        saga::task checkpoint(saga::cpr::job,saga::python::routine_type [,saga::url])

Overrides: job._job.job.checkpoint

cpr_last(...)


cpr_last( (job)arg1) -> url :
    get last known checkpoint (plain)

    C++ signature :
        saga::url cpr_last(saga::cpr::job)

cpr_last( (job)arg1, (routine_type)arg2) -> task :
    get last known checkpoint (task based)

    C++ signature :
        saga::task cpr_last(saga::cpr::job,saga::python::routine_type)

cpr_list(...)


cpr_list( (job)arg1) -> object :
    get list of known checkpoints (plain)

    C++ signature :
        std::vector<saga::url, std::allocator<saga::url> > cpr_list(saga::cpr::job)

cpr_list( (job)arg1, (routine_type)arg2) -> task :
    get list of known checkpoints (task based)

    C++ signature :
        saga::task cpr_list(saga::cpr::job,saga::python::routine_type)

cpr_stage_in(...)


cpr_stage_in( (job)arg1 [, (url)arg2]) -> None :
    stage-in a checpoint file (plain)

    C++ signature :
        void cpr_stage_in(saga::cpr::job [,saga::url])

cpr_stage_in( (job)arg1, (routine_type)arg2 [, (url)arg3]) -> task :
    stage-in a checpoint file (task based)

    C++ signature :
        saga::task cpr_stage_in(saga::cpr::job,saga::python::routine_type [,saga::url])

cpr_stage_out(...)


cpr_stage_out( (job)arg1 [, (url)arg2]) -> None :
    stage-out a checpoint file (plain)

    C++ signature :
        void cpr_stage_out(saga::cpr::job [,saga::url])

cpr_stage_out( (job)arg1, (routine_type)arg2 [, (url)arg3]) -> task :
    stage-out a checpoint file (task based)

    C++ signature :
        saga::task cpr_stage_out(saga::cpr::job,saga::python::routine_type [,saga::url])

recover(...)


recover( (job)arg1 [, (url)arg2]) -> None :
    recover a job (plain)

    C++ signature :
        void recover(saga::cpr::job [,saga::url])

recover( (job)arg1, (routine_type)arg2 [, (url)arg3]) -> task :
    recover a job (task based)

    C++ signature :
        saga::task recover(saga::cpr::job,saga::python::routine_type [,saga::url])