Index Symbols | A | B | C | D | E | F | G | H | I | K | L | M | N | O | P | R | S | T | U | V | W Symbols --address covalent-cluster command line option, [1] --develop covalent-restart command line option, [1] covalent-start command line option, [1] --hard covalent-purge command line option, [1] --ignore-migrations covalent-start command line option, [1] --info covalent-cluster command line option, [1] --logs covalent-cluster command line option, [1] --mem-per-worker <mem_per_worker> covalent-start command line option, [1] --no-cluster covalent-start command line option, [1] --no-triggers covalent-start command line option, [1] --port <port> covalent-restart command line option, [1] covalent-start command line option, [1] --restart covalent-cluster command line option, [1] --scale <scale> covalent-cluster command line option, [1] --size covalent-cluster command line option, [1] --status covalent-cluster command line option, [1] --threads-per-worker <threads_per_worker> covalent-start command line option, [1] --triggers-only covalent-start command line option, [1] --version covalent command line option, [1] --workers <workers> covalent-start command line option, [1] --yes covalent-purge command line option, [1] -d covalent-restart command line option, [1] covalent-start command line option, [1] -H covalent-purge command line option, [1] -m covalent-start command line option, [1] -n covalent-start command line option, [1] -p covalent-restart command line option, [1] covalent-start command line option, [1] -t covalent-start command line option, [1] -v covalent command line option, [1] -y covalent-purge command line option, [1] A add_collection_node_to_graph() (covalent._workflow.electron.Electron method), [1] AFTER (covalent.fs.Order attribute) ALEMBIC_ARGS covalent-db-alembic command line option, [1] API apply() (covalent._workflow.deps.Deps method) apply_args (covalent._workflow.deps.Deps attribute) apply_fn (covalent._workflow.deps.Deps attribute) apply_kwargs (covalent._workflow.deps.Deps attribute) args (covalent._workflow.depscall.DepsCall attribute) (covalent.DepsCall attribute), [1] argtypes (covalent.Lepton attribute) as_transportable_dict (covalent._workflow.electron.Electron property), [1] AsyncBaseExecutor (class in covalent.executor.base) attach_methods_to_handler() (covalent.triggers.DirTrigger method), [1] attrs (covalent.TransportableObject property) B BaseExecutor (class in covalent.executor.base) BaseTrigger (class in covalent.triggers), [1] bash() (in module covalent.leptons) batch_size (covalent.triggers.DirTrigger.self attribute), [1] BEFORE (covalent.fs.Order attribute) build_graph() (covalent._workflow.lattice.Lattice method), [1] C cache_dir (covalent.executor.base.AsyncBaseExecutor attribute) (covalent.executor.base.BaseExecutor attribute) cancel() (covalent.executor.base.AsyncBaseExecutor method) (covalent.executor.base.BaseExecutor method) (covalent.executor.executor_plugins.dask.DaskExecutor method), [1] (covalent.executor.executor_plugins.local.LocalExecutor method), [1] (in module covalent) (in module covalent._results_manager.results_manager) Cluster commands (covalent._workflow.depsbash.DepsBash attribute) (covalent.DepsBash attribute), [1] connect_node_with_others() (covalent._workflow.electron.Electron method), [1] Contributor Covalent covalent module, [1] covalent command line option --version, [1] -v, [1] covalent-cluster command line option --address, [1] --info, [1] --logs, [1] --restart, [1] --scale <scale>, [1] --size, [1] --status, [1] covalent-db-alembic command line option ALEMBIC_ARGS, [1] covalent-migrate-legacy-result-object command line option RESULT_PICKLE_PATH covalent-purge command line option --hard, [1] --yes, [1] -H, [1] -y, [1] covalent-restart command line option --develop, [1] --port <port>, [1] -d, [1] -p, [1] covalent-start command line option --develop, [1] --ignore-migrations, [1] --mem-per-worker <mem_per_worker>, [1] --no-cluster, [1] --no-triggers, [1] --port <port>, [1] --threads-per-worker <threads_per_worker>, [1] --triggers-only, [1] --workers <workers>, [1] -d, [1] -m, [1] -n, [1] -p, [1] -t, [1] covalent.fs module covalent.fs_strategies module covalent.leptons module covalent.triggers module, [1] cp() (covalent.fs.FileTransfer method) (covalent.fs_strategies.HTTP method) (covalent.fs_strategies.Rsync method) (covalent.fs_strategies.S3 method) Credentials D Dask DaskExecutor (class in covalent.executor.executor_plugins.dask), [1] Deps (class in covalent._workflow.deps) DepsBash (class in covalent), [1] (class in covalent._workflow.depsbash) DepsCall (class in covalent), [1] (class in covalent._workflow.depscall) DepsPip (class in covalent), [1] (class in covalent._workflow.depspip) deserialize() (covalent.TransportableObject static method) deserialize_dict() (covalent.TransportableObject static method) deserialize_from_json() (covalent.TransportableObject static method) deserialize_list() (covalent.TransportableObject static method) dir_path (covalent.triggers.DirTrigger.self attribute), [1] DirTrigger (class in covalent.triggers), [1] Dispatch dispatch() (covalent._workflow.lattice.Lattice method), [1] (in module covalent), [1] dispatch_id (covalent._results_manager.result.Result attribute), [1] (covalent._results_manager.result.Result property), [1] dispatch_sync() (covalent._workflow.lattice.Lattice method), [1] (in module covalent), [1] dispatcher_addr (covalent.triggers.BaseTrigger.self attribute), [1] download() (covalent.fs_strategies.HTTP method) (covalent.fs_strategies.Rsync method) (covalent.fs_strategies.S3 method) draw() (covalent._workflow.lattice.Lattice method), [1] E Electron (class in covalent._workflow.electron), [1] electron() (in module covalent), [1], [2] electron_outputs (covalent._workflow.lattice.Lattice attribute), [1] encoded_result (covalent._results_manager.result.Result property), [1] end_time (covalent._results_manager.result.Result property), [1] error (covalent._results_manager.result.Result attribute), [1] (covalent._results_manager.result.Result property), [1] event_loop (covalent.triggers.BaseTrigger.self attribute), [1] event_names (covalent.triggers.DirTrigger.self attribute), [1] execute() (covalent.executor.base.BaseExecutor method) (covalent.executor.executor_plugins.local.LocalExecutor method), [1] Executor executor (covalent.Lepton attribute) Experiment F File (class in covalent._file_transfer.file) (class in covalent.fs) filepath (covalent._file_transfer.file.File attribute) (covalent.fs.File attribute) (covalent.fs.File property) files (covalent.Lepton attribute) FileTransfer (class in covalent._file_transfer.file_transfer) (class in covalent.fs) FileTransferStrategy (class in covalent._file_transfer.strategies.transfer_strategy_base) Folder (class in covalent._file_transfer.folder) (class in covalent.fs) from_dict() (covalent._workflow.depsbash.DepsBash method) (covalent._workflow.depscall.DepsCall method) (covalent._workflow.depspip.DepsPip method) (covalent.DepsBash method), [1] (covalent.DepsCall method), [1] (covalent.DepsPip method), [1] (covalent.executor.base.AsyncBaseExecutor method) (covalent.executor.base.BaseExecutor method) (covalent.executor.executor_plugins.dask.DaskExecutor method), [1] (covalent.executor.executor_plugins.local.LocalExecutor method), [1] (covalent.TransportableObject static method) from_file (covalent._file_transfer.file_transfer.FileTransfer attribute) (covalent.fs.FileTransfer attribute) func (covalent._workflow.depscall.DepsCall attribute) (covalent.DepsCall attribute), [1] Function function (covalent._workflow.electron.Electron attribute), [1] function_name (covalent.Lepton attribute) G get_all_node_outputs() (covalent._results_manager.result.Result method), [1] get_all_node_results() (covalent._results_manager.result.Result method), [1] get_cancel_requested() (covalent.executor.base.AsyncBaseExecutor method) (covalent.executor.base.BaseExecutor method) (covalent.executor.executor_plugins.dask.DaskExecutor method), [1] (covalent.executor.executor_plugins.local.LocalExecutor method), [1] get_config() (in module covalent) get_deserialized() (covalent.TransportableObject method) get_dispatch_context() (covalent.executor.base.AsyncBaseExecutor method) (covalent.executor.base.BaseExecutor method) (covalent.executor.executor_plugins.dask.DaskExecutor method), [1] (covalent.executor.executor_plugins.local.LocalExecutor method), [1] get_metadata() (covalent._workflow.electron.Electron method), [1] (covalent._workflow.lattice.Lattice method), [1] get_node_result() (covalent._results_manager.result.Result method), [1] get_op_function() (covalent._workflow.electron.Electron method), [1] get_path_obj() (covalent.fs.File static method) get_result() (in module covalent), [1] get_rsync_cmd() (covalent.fs_strategies.Rsync method) get_rsync_ssh_cmd() (covalent.fs_strategies.Rsync method) get_serialized() (covalent.TransportableObject method) get_temp_filepath() (covalent.fs.File method) get_uri() (covalent.fs.File static method) GUI H Host host (covalent._file_transfer.strategies.rsync_strategy.Rsync attribute) (covalent.fs_strategies.Rsync attribute) HTTP (class in covalent.fs_strategies) I include_folder (covalent._file_transfer.file.File attribute) (covalent._file_transfer.folder.Folder attribute) (covalent.fs.File attribute) (covalent.fs.Folder attribute) INPUT (covalent.Lepton attribute) INPUT_OUTPUT (covalent.Lepton attribute) inputs (covalent._results_manager.result.Result attribute), [1] (covalent._results_manager.result.Result property), [1] is_dir (covalent._file_transfer.file.File attribute) (covalent.fs.File attribute) (covalent.fs.File property) is_remote (covalent._file_transfer.file.File attribute) (covalent.fs.File attribute) (covalent.fs.File property) is_temp_file (covalent.fs.File property) K kwargs (covalent._workflow.depscall.DepsCall attribute) (covalent._workflow.electron.Electron attribute), [1] (covalent._workflow.lattice.Lattice attribute), [1] (covalent.DepsCall attribute), [1] L language (covalent.Lepton attribute) Lattice (class in covalent._workflow.lattice), [1] lattice (covalent._results_manager.result.Result attribute), [1] (covalent._results_manager.result.Result property), [1] lattice() (in module covalent), [1], [2] lattice_dispatch_id (covalent.triggers.BaseTrigger.self attribute), [1] Lepton (class in covalent) library_name (covalent.Lepton attribute) Local LocalExecutor (class in covalent.executor.executor_plugins.local), [1] log_stderr (covalent.executor.base.AsyncBaseExecutor attribute) (covalent.executor.base.BaseExecutor attribute) log_stdout (covalent.executor.base.AsyncBaseExecutor attribute) (covalent.executor.base.BaseExecutor attribute) M make_transportable() (covalent.TransportableObject static method) Management mapped_strategy_type (covalent.fs.File property) metadata (covalent._workflow.electron.Electron attribute), [1] (covalent._workflow.lattice.Lattice attribute), [1] module covalent, [1] covalent.fs covalent.fs_strategies covalent.leptons covalent.triggers, [1] N n_changes (covalent.triggers.DirTrigger.self attribute), [1] new_dispatch_ids (covalent.triggers.BaseTrigger.self attribute), [1] node_id (covalent._workflow.electron.Electron attribute), [1] O object_string (covalent.TransportableObject property) observe() (covalent.triggers.BaseTrigger method), [1] (covalent.triggers.DirTrigger method), [1] (covalent.triggers.TimeTrigger method), [1] observe_blocks (covalent.triggers.BaseTrigger.self attribute), [1] Order (class in covalent.fs) order (covalent._file_transfer.file_transfer.FileTransfer attribute) (covalent.fs.FileTransfer attribute) OUTPUT (covalent.Lepton attribute) P packages (covalent._workflow.depspip.DepsPip attribute) (covalent.DepsPip attribute), [1] packing_tasks (covalent._workflow.electron.Electron attribute), [1] Parallelism post_process() (covalent._results_manager.result.Result method), [1] post_processing (covalent._workflow.lattice.Lattice attribute), [1] private_key_path (covalent._file_transfer.strategies.rsync_strategy.Rsync attribute) (covalent.fs_strategies.Rsync attribute) Python python_version (covalent.TransportableObject property) R recursive (covalent.triggers.DirTrigger.self attribute), [1] redispatch() (in module covalent), [1] register() (covalent.triggers.BaseTrigger method), [1] reload_config() (in module covalent) Remote reqs_path (covalent._workflow.depspip.DepsPip attribute) (covalent.DepsPip attribute), [1] resolve_scheme() (covalent.fs.File static method) Result (class in covalent._results_manager.result), [1] result (covalent._results_manager.result.Result attribute), [1] (covalent._results_manager.result.Result property), [1] RESULT_PICKLE_PATH covalent-migrate-legacy-result-object command line option results_dir (covalent._results_manager.result.Result attribute), [1] (covalent._results_manager.result.Result property), [1] retries (covalent.executor.base.AsyncBaseExecutor attribute) (covalent.executor.base.BaseExecutor attribute) return_subprocess_callable() (covalent.fs_strategies.Rsync method) retval_keyword (covalent._workflow.depscall.DepsCall attribute) (covalent.DepsCall attribute), [1] root_dispatch_id (covalent._results_manager.result.Result attribute), [1] (covalent._results_manager.result.Result property), [1] Rsync (class in covalent._file_transfer.strategies.rsync_strategy) (class in covalent.fs_strategies) run() (covalent.executor.base.AsyncBaseExecutor method) (covalent.executor.base.BaseExecutor method) (covalent.executor.executor_plugins.dask.DaskExecutor method), [1] (covalent.executor.executor_plugins.local.LocalExecutor method), [1] S S3 (class in covalent.fs_strategies) Scheduler SDK serialize() (covalent.TransportableObject method) serialize_to_json() (covalent.TransportableObject method) Server set_config() (in module covalent) set_job_handle() (covalent.executor.base.AsyncBaseExecutor method) (covalent.executor.base.BaseExecutor method) (covalent.executor.executor_plugins.dask.DaskExecutor method), [1] (covalent.executor.executor_plugins.local.LocalExecutor method), [1] set_metadata() (covalent._workflow.electron.Electron method), [1] (covalent._workflow.lattice.Lattice method), [1] setup() (covalent.executor.base.AsyncBaseExecutor method) (covalent.executor.base.BaseExecutor method) (covalent.executor.executor_plugins.dask.DaskExecutor method), [1] (covalent.executor.executor_plugins.local.LocalExecutor method), [1] start_time (covalent._results_manager.result.Result property), [1] status (covalent._results_manager.result.Result attribute), [1] (covalent._results_manager.result.Result property), [1] (in module covalent) stop() (covalent.triggers.BaseTrigger method), [1] (covalent.triggers.DirTrigger method), [1] (covalent.triggers.TimeTrigger method), [1] stop_flag (covalent.triggers.BaseTrigger.self attribute), [1] (covalent.triggers.TimeTrigger.self attribute), [1] stop_triggers() (in module covalent), [1] strategy (covalent._file_transfer.file_transfer.FileTransfer attribute) (covalent.fs.FileTransfer attribute) Sublattice Subtask sync() (in module covalent) T Task task_group_id (covalent._workflow.electron.Electron attribute), [1] teardown() (covalent.executor.base.AsyncBaseExecutor method) (covalent.executor.base.BaseExecutor method) (covalent.executor.executor_plugins.dask.DaskExecutor method), [1] (covalent.executor.executor_plugins.local.LocalExecutor method), [1] time_gap (covalent.triggers.TimeTrigger.self attribute), [1] time_limit (covalent.executor.base.AsyncBaseExecutor attribute) (covalent.executor.base.BaseExecutor attribute) TimeTrigger (class in covalent.triggers), [1] to_dict() (covalent._workflow.depsbash.DepsBash method) (covalent._workflow.depscall.DepsCall method) (covalent._workflow.depspip.DepsPip method) (covalent.DepsBash method), [1] (covalent.DepsCall method), [1] (covalent.DepsPip method), [1] (covalent.executor.base.AsyncBaseExecutor method) (covalent.executor.base.BaseExecutor method) (covalent.executor.executor_plugins.dask.DaskExecutor method), [1] (covalent.executor.executor_plugins.local.LocalExecutor method), [1] (covalent.TransportableObject method) (covalent.triggers.BaseTrigger method), [1] to_file (covalent._file_transfer.file_transfer.FileTransfer attribute) (covalent.fs.FileTransfer attribute) touch() (covalent.fs.File method) TransferFromRemote() (in module covalent._file_transfer.file_transfer) (in module covalent.fs) TransferToRemote() (in module covalent._file_transfer.file_transfer) (in module covalent.fs) Transport Graph transport_graph (covalent._workflow.lattice.Lattice attribute), [1] TransportableObject (class in covalent) trigger() (covalent.triggers.BaseTrigger method), [1] triggers_server_addr (covalent.triggers.BaseTrigger.self attribute), [1] U upload() (covalent.fs_strategies.HTTP method) (covalent.fs_strategies.Rsync method) (covalent.fs_strategies.S3 method) use_internal_funcs (covalent.triggers.BaseTrigger.self attribute), [1] User user (covalent._file_transfer.strategies.rsync_strategy.Rsync attribute) (covalent.fs_strategies.Rsync attribute) V VM W wait() (in module covalent) wait_for() (covalent._workflow.electron.Electron method), [1] Workflow workflow_function (covalent._workflow.lattice.Lattice attribute), [1] wrap_task() (covalent.Lepton method) write_streams_to_file() (covalent.executor.base.AsyncBaseExecutor method) (covalent.executor.base.BaseExecutor method) (covalent.executor.executor_plugins.dask.DaskExecutor method), [1] (covalent.executor.executor_plugins.local.LocalExecutor method), [1]