Project Manager Module#

nexus.project_manager.trivial(sim, *args, **kwargs)[source]#
class nexus.project_manager.ProjectManager[source]#

Bases: NexusCore

Attributes:
machine
working_directory

Methods

append(value)

class_error(message[, header, exit, trace, ...])

Report an error relating to a class.

enter(directory[, changedir, msg])

Have Nexus enter a directory and change its current working directory.

error(message[, header, exit, trace])

Report an error inside a class.

first()

keys()

list(*keys)

log(*texts, **kwargs)

Write output to log file.

open_log(filepath)

save([fpath])

sorted_keys()

warn(msg[, indent])

Warning from inside a Nexus class.

write_cascade_dependents()

write_sim_dependencies([idkey])

add

add_cascade

add_optional

add_simulations

check_dependencies

check_required

check_types

check_types_optional

class_get

class_has

class_items

class_keys

class_log

class_set

class_set_optional

class_set_single

class_warn

clear

close_log

copy

copy_from

copy_to

data_repr

delete

delete_optional

delete_required

dict

dlog

extract

extract_optional

get

get_optional

get_path

get_required

init_cascades

inverse

items

last

leave

list_optional

load

load_cascades

mem_usage

move_from

move_from_optional

move_to

move_to_optional

not_implemented

obj

path_exists

progress_cascades

propagate_blockages

random_key

resolve_file_collisions

restore_default_settings

run_project

screen_fake_sims

select_random

serial

set

set_optional

set_path

shallow_copy

status_line

tlog

to_dict

to_obj

transfer_from

transfer_to

traverse_cascades

tree

tuple

update_process_ids

values

write

write_end_splash

write_simulation_status

write_splash

machine = None#
static restore_default_settings()[source]#
add_simulations(*simulations)[source]#
add_cascade(cascade)[source]#
run_project(status=False, status_only=False)[source]#
init_cascades()[source]#
screen_fake_sims()[source]#
resolve_file_collisions()[source]#
propagate_blockages()[source]#
load_cascades()[source]#
check_dependencies()[source]#
traverse_cascades(operation=<function trivial>, *args, **kwargs)[source]#
write_simulation_status()[source]#
status_line(sim, extra='')[source]#
progress_cascades()[source]#
update_process_ids()[source]#
write_sim_dependencies(idkey=None)[source]#
write_cascade_dependents()[source]#
class nexus.project_manager.DynamicWorkflowManager[source]#

Bases: NexusCore

Replacement for ProjectManager for dynamic workflows

Attributes:
working_directory

Methods

append(value)

class_error(message[, header, exit, trace, ...])

Report an error relating to a class.

enter(directory[, changedir, msg])

Have Nexus enter a directory and change its current working directory.

error(message[, header, exit, trace])

Report an error inside a class.

first()

keys()

list(*keys)

log(*texts, **kwargs)

Write output to log file.

open_log(filepath)

save([fpath])

sorted_keys()

warn(msg[, indent])

Warning from inside a Nexus class.

add

add_new_dyn_procs

add_optional

check_required

check_types

check_types_optional

class_get

class_has

class_items

class_keys

class_log

class_set

class_set_optional

class_set_single

class_warn

clear

close_log

copy

copy_from

copy_to

data_repr

delete

delete_optional

delete_required

dict

dlog

extract

extract_optional

get

get_optional

get_path

get_required

inverse

items

last

leave

list_optional

load

mem_usage

move_from

move_from_optional

move_to

move_to_optional

not_implemented

obj

path_exists

poll

random_key

select_random

serial

set

set_optional

set_path

shallow_copy

tlog

to_dict

to_obj

transfer_from

transfer_to

tree

tuple

values

write

write_end_splash

write_splash

all_dp = {}#
all_sims = {}#
add_new_dyn_procs()[source]#
poll(sleep=None)[source]#
nexus.project_manager.workflow_manager(**kw)[source]#