Index

A

abort_scheduling() (pipelet.scheduler.Scheduler method) AbortError acl_setup() (in module pipelet.auth) add_queued() (pipelet.tracker.SqliteTracker method) (pipelet.tracker.Tracker method)

add_tag() (in module pipelet.db_utils) add_user() (in module pipelet.auth) addtag() (pipelet.treeview.TreeView method) ask_auth() (in module pipelet.auth)

B

base32_digest() (pipelet.utils.crc32 method)

C

catch_sigterm() (in module pipelet.worker) change_root() (in module pipelet.db_utils) check_access() (in module pipelet.auth) check_in() (pipelet.scheduler.Scheduler method) check_out() (pipelet.scheduler.Scheduler method) check_path() (pipelet.treeview.TreeView method) clean() (pipelet.tracker.SqliteTracker method) clean_tmp() (pipelet.environment.Environment method)

close() (pipelet.tracker.SqliteTracker method) close_logger() (in module pipelet.utils) code() (pipelet.treeview.TreeView method) compute_hash() (pipelet.pipeline.Pipeline method) connect() (pipelet.pipeline.Pipeline method) crc32 (class in pipelet.utils) create_pipe() (in module pipelet.utils) cross_prod() (in module pipelet.multiplex)

D

del_lst_prod() (pipelet.treeview.TreeView method) del_lst_seg() (pipelet.treeview.TreeView method) del_tag() (in module pipelet.db_utils) del_user() (in module pipelet.auth) delete_log() (pipelet.treeview.TreeView method)

deltag() (pipelet.treeview.TreeView method) deltask() (in module pipelet.db_utils) Depend (class in pipelet.directive) Directive (class in pipelet.directive) download() (pipelet.treeview.TreeView method)

E

emit() (pipelet.scheduler.NullHandler method) (pipelet.worker.NullHandler method) Environment (class in pipelet.environment) environment (module) exec_code() (pipelet.worker.InteractiveWorker method) (pipelet.worker.Worker method)

execute_task() (pipelet.worker.Worker method) expose() (pipelet.environment.Environment method) exposed (pipelet.treeview.TreeView attribute)

F

filter() (pipelet.treeview.TreeView method) filter_panel() (pipelet.treeview.TreeView method) find_seg() (pipelet.pipeline.Pipeline method) flatten() (in module pipelet.utils) (pipelet.pipeline.Pipeline method)

flush() (pipelet.tracker.SqliteTracker method) forbidden_path (pipelet.treeview.TreeView attribute) from_dot() (pipelet.pipeline.Pipeline method)

G

get_all_string() (pipelet.repository.Repository method) get_childrens() (pipelet.pipeline.Pipeline method) get_code_source() (pipelet.repository.LocalRepository static method) get_code_string() (pipelet.repository.Repository method) get_config() (pipelet.web.PipeIndex method) get_credentials() (in module pipelet.auth) get_curr_dir() (pipelet.pipeline.Pipeline method) get_data_dir() (pipelet.pipeline.Pipeline method) get_data_fn() (pipelet.environment.Environment method) get_deps_string() (pipelet.repository.Repository method) get_directive() (pipelet.repository.Repository method) get_docline() (pipelet.repository.Repository method) get_done() (pipelet.tracker.Tracker method) get_failed() (pipelet.tracker.Tracker method) get_file_content() (pipelet.repository.Repository static method) get_fns() (pipelet.repository.LocalRepository method) (pipelet.repository.Repository method) get_full_seg_name() (pipelet.pipeline.Pipeline method) get_hashkey() (in module pipelet.utils) get_hook_list() (pipelet.repository.Repository method) get_hook_string() (pipelet.repository.Repository method) get_html_refresh() (pipelet.treeview.TreeView method) get_input() (pipelet.environment.Environment method) get_last() (in module pipelet.db_utils)

get_list_status() (pipelet.tracker.SqliteTracker method) (pipelet.tracker.Tracker method) get_list_status_old() (pipelet.tracker.SqliteTracker method) get_log_dir() (pipelet.pipeline.Pipeline method) get_log_file() (in module pipelet.utils) (pipelet.pipeline.Pipeline method) get_lst_date() (in module pipelet.db_utils) get_lst_seg() (in module pipelet.db_utils) get_lst_tag() (in module pipelet.db_utils) get_meta_file() (pipelet.pipeline.Pipeline method) get_param_file() (pipelet.pipeline.Pipeline method) get_parent() (pipelet.environment.Environment method) get_parents() (pipelet.pipeline.Pipeline method) get_pipe() (pipelet.scheduler.Scheduler method) get_queued() (pipelet.tracker.Tracker method) get_running() (pipelet.tracker.Tracker method) get_scheduler() (pipelet.worker.SchedulerManager method) get_status() (pipelet.tracker.SqliteTracker method) (pipelet.tracker.Tracker method) get_tag_file() (pipelet.pipeline.Pipeline method) get_task() (pipelet.scheduler.Scheduler method) get_tmp_fn() (pipelet.environment.Environment method) gettest() (pipelet.tracker.SqliteTracker method) gettest2() (pipelet.tracker.SqliteTracker method) glob_parent() (pipelet.environment.Environment method) glob_seg() (pipelet.environment.Environment method)

H

hook() (pipelet.environment.Environment method)

html_tmp (pipelet.web.PipeIndex attribute)

I

index() (pipelet.treeview.TreeView method) (pipelet.web.PipeIndex method) init_logger() (in module pipelet.utils)

InteractiveWorker (class in pipelet.worker) is_code_file() (in module pipelet.utils)

L

launch_ccage_server() (in module pipelet.launchers) launch_ccage_worker() (in module pipelet.launchers) launch_ccali() (in module pipelet.launchers) launch_ccali_ge() (in module pipelet.launchers) launch_interactive() (in module pipelet.launchers) launch_nersc() (in module pipelet.launchers) launch_pbs() (in module pipelet.launchers) launch_process() (in module pipelet.launchers)

launch_ssh() (in module pipelet.launchers) launch_thread() (in module pipelet.launchers) load_param() (pipelet.environment.Environment method) load_products() (pipelet.environment.Environment method) LocalRepository (class in pipelet.repository) log() (pipelet.treeview.TreeView method) logged_subprocess() (pipelet.environment.Environment method)

M

main() (in module pipelet.web) make_dict() (in module pipelet.utils) make_dir() (pipelet.worker.Worker method) matplotlib_hook() (pipelet.worker.InteractiveWorker method) (pipelet.worker.Worker method)

Multiplex (class in pipelet.directive) multiplex() (pipelet.task.TaskList method) MyApp (class in pipelet.web)

N

NullHandler (class in pipelet.scheduler) (class in pipelet.worker)

O

old_to_new() (in module pipelet.db_utils)

P

parse() (pipelet.directive.Directive method) parse_disk() (in module pipelet.utils) pipedir() (pipelet.treeview.TreeView method) PipeException PipeIndex (class in pipelet.web) pipelet (module), [1] pipelet.auth (module) pipelet.db_utils (module) pipelet.directive (module) pipelet.environment (module) pipelet.launchers (module) pipelet.multiplex (module) pipelet.pipeline (module) pipelet.repository (module) pipelet.scheduler (module)

pipelet.task (module) pipelet.tracker (module) pipelet.treeview (module) pipelet.utils (module) pipelet.web (module) pipelet.worker (module) Pipeline (class in pipelet.pipeline) pop() (pipelet.task.TaskList method) prepare_env() (pipelet.worker.Worker method) ProcessWorker (class in pipelet.worker) product() (pipelet.treeview.TreeView method) push() (pipelet.pipeline.Pipeline method) (pipelet.task.TaskList method) push_next_seg() (pipelet.scheduler.Scheduler method) put_task() (pipelet.scheduler.Scheduler method)

R

read_access() (in module pipelet.auth) rebuild_db_from_disk() (in module pipelet.utils) reduced_code_formatting() (in module pipelet.utils)

Repository (class in pipelet.repository) requeue() (pipelet.scheduler.Scheduler method) run() (pipelet.scheduler.Scheduler method) (pipelet.tracker.SqliteTracker method) (pipelet.worker.ProcessWorker method) (pipelet.worker.Worker method)

S

SandBox (class in pipelet.worker) save_param() (pipelet.environment.Environment method) save_products() (pipelet.environment.Environment method) Scheduler (class in pipelet.scheduler) SchedulerManager (class in pipelet.launchers) (class in pipelet.worker) segments_registration() (pipelet.tracker.SqliteTracker method) serve_log() (pipelet.treeview.TreeView method) serve_pickle() (pipelet.treeview.TreeView method) set_output() (pipelet.environment.Environment method) setup() (pipelet.worker.SandBox method)

spl() (in module pipelet.utils) SqliteTracker (class in pipelet.tracker) start() (in module pipelet.web) stop() (in module pipelet.web) (pipelet.tracker.SqliteTracker method) store_meta() (pipelet.task.Task method) store_meta_seg() (pipelet.scheduler.Scheduler method) str_date() (in module pipelet.utils) str_file() (in module pipelet.utils) str_web() (in module pipelet.utils) strseg() (pipelet.pipeline.Pipeline method)

T

Task (class in pipelet.task) task_done() (pipelet.scheduler.Scheduler method) task_failed() (pipelet.scheduler.Scheduler method) TaskList (class in pipelet.task) terminate() (pipelet.worker.InteractiveWorker method) (pipelet.worker.Worker method) ThreadWorker (class in pipelet.worker)

thumbnail_panel() (pipelet.treeview.TreeView method) to_dot() (pipelet.pipeline.Pipeline method) Tracker (class in pipelet.tracker) TreeView (class in pipelet.treeview) treeview_panel() (pipelet.treeview.TreeView method)

U

union() (in module pipelet.multiplex) update() (pipelet.utils.crc32 method) update_config() (in module pipelet.web)

update_param() (pipelet.tracker.SqliteTracker method) update_status() (pipelet.task.Task method) (pipelet.tracker.SqliteTracker method) (pipelet.tracker.Tracker method) upgrade_webconfig() (in module pipelet.utils)

W

which_sqlfile() (pipelet.web.PipeIndex method) which_view() (pipelet.web.PipeIndex method)

Worker (class in pipelet.worker) write_access() (in module pipelet.auth)