pcvs.orchestration package

Submodules

• pcvs.orchestration.publishers module
  • BuildDirectoryManager
    • BuildDirectoryManager.add_cache_entry()
    • BuildDirectoryManager.clean()
    • BuildDirectoryManager.clean_archives()
    • BuildDirectoryManager.config
    • BuildDirectoryManager.create_archive()
    • BuildDirectoryManager.finalize()
    • BuildDirectoryManager.get_cache_entry()
    • BuildDirectoryManager.get_config()
    • BuildDirectoryManager.init_results()
    • BuildDirectoryManager.load_config()
    • BuildDirectoryManager.load_from_archive()
    • BuildDirectoryManager.prefix
    • BuildDirectoryManager.prepare()
    • BuildDirectoryManager.results
    • BuildDirectoryManager.save_config()
    • BuildDirectoryManager.save_extras()
    • BuildDirectoryManager.scratch_location
    • BuildDirectoryManager.sid
    • BuildDirectoryManager.use_as_global_config()
  • ResultFile
    • ResultFile.MAGIC_TOKEN
    • ResultFile.close()
    • ResultFile.content
    • ResultFile.count
    • ResultFile.extract_output()
    • ResultFile.flush()
    • ResultFile.load()
    • ResultFile.metadata_prefix
    • ResultFile.prefix
    • ResultFile.rawdata_prefix
    • ResultFile.retrieve_test()
    • ResultFile.save()
    • ResultFile.size
  • ResultFileManager
    • ResultFileManager.browse_tests()
    • ResultFileManager.build_bidir_map_data()
    • ResultFileManager.create_new_result_file()
    • ResultFileManager.discover_result_files()
    • ResultFileManager.file_format
    • ResultFileManager.finalize()
    • ResultFileManager.flush()
    • ResultFileManager.increment
    • ResultFileManager.map_id()
    • ResultFileManager.maps
    • ResultFileManager.reconstruct_map_data()
    • ResultFileManager.reconstruct_view_data()
    • ResultFileManager.register_view()
    • ResultFileManager.register_view_item()
    • ResultFileManager.retrieve_test()
    • ResultFileManager.retrieve_tests_by_name()
    • ResultFileManager.save()
    • ResultFileManager.status_view
    • ResultFileManager.subtree_view()
    • ResultFileManager.tags_view
    • ResultFileManager.total_cnt
    • ResultFileManager.tree_view
    • ResultFileManager.views

Module contents

class pcvs.orchestration.Orchestrator

Bases: object

The job orchestrator, managing test processing through the whole test base.

Variables:

• _conf – global configuration object

• _pending_sets – started Sets not completed yet

• _max_res – number of resources allowed to be used

• _publisher – Result File Manager

• _manager – job manager

• _maxconcurrent – Max number of sets started at the same time.

add_new_job(job)

Append a new job to be scheduled.

Parameters:

job (Test) – job to append

print_infos()

display pre-run infos.

run(session)

Start the orchestrator.

Parameters:

session (Session) – container owning the run.

start_new_runner()

Start a new Runner thread & register comm queues.

start_run(the_session=None, restart=False)

Start the orchestrator.

Parameters:

• the_session (Session) – container owning the run.

• restart (False for a brand new run.) – whether the run is starting from scratch

classmethod stop()

Request runner threads to stop.

stop_runners()

Stop all previously started runners.

Wait for their completion.

pcvs.orchestration.global_stop(e)