Index

A

absolutize() (in module dflow.python.utils) absolutize_hdf5() (in module dflow.python.utils) action (dflow.Resource attribute) (dflow.resource.Resource attribute) add() (dflow.DAG method) (dflow.dag.DAG method) (dflow.Steps method) (dflow.steps.Steps method) (dflow.Workflow method) (dflow.workflow.Workflow method) add_slices() (dflow.DAG method) (dflow.dag.DAG method) (dflow.python.python_op_template.PythonOPTemplate method) (dflow.python.PythonOPTemplate method) (dflow.Steps method) (dflow.steps.Steps method) (in module dflow.step) append_item() (in module dflow.utils) argo_concat() (in module dflow) (in module dflow.step) argo_enumerate() (in module dflow) (in module dflow.step) argo_len() (in module dflow) (in module dflow.step) argo_range() (in module dflow) (in module dflow.step) argo_sequence() (in module dflow) (in module dflow.step)

argo_sum() (in module dflow) (in module dflow.step) ArgoConcat (class in dflow.step) ArgoEnumerate (class in dflow.step) ArgoLen (class in dflow.step) ArgoObjectDict (class in dflow.argo_objects) ArgoObjectList (class in dflow.argo_objects) ArgoParameter (class in dflow.argo_objects) ArgoRange (class in dflow.step) ArgoSequence (class in dflow.step) ArgoStep (class in dflow) (class in dflow.argo_objects) ArgoSum (class in dflow.step) ArgoVar (class in dflow.io) ArgoWorkflow (class in dflow) (class in dflow.argo_objects) Artifact (class in dflow.python) (class in dflow.python.opio) ArtifactDict (class in dflow.utils) ArtifactList (class in dflow.utils) ArtifactPosixPath (class in dflow.utils) ArtifactSet (class in dflow.utils) ArtifactStr (class in dflow.utils) ArtifactWindowsPath (class in dflow.utils) assemble_path_object() (in module dflow.utils) assemble_path_object_from_catalog() (in module dflow.utils) AutonamedDict (class in dflow) (class in dflow.io)

B

backup() (in module dflow.step) BigParameter (class in dflow.python) (class in dflow.python.opio) bohrium_download() (dflow.plugins.bohrium.BohriumDatasetsArtifact method) (dflow.plugins.datasets.DatasetsArtifact method) (dflow.plugins.dispatcher.DispatcherArtifact method)

BohriumContext (class in dflow.plugins.bohrium) BohriumDatasetsArtifact (class in dflow.plugins.bohrium) BohriumExecutor (class in dflow.plugins.bohrium) boolize() (in module dflow.config)

C

catalog_of_artifact() (in module dflow.utils) catalog_of_local_artifact() (in module dflow.utils) CheckNumSuccess (class in dflow.util_ops) CheckSuccessRatio (class in dflow.util_ops) CodeGenerator (class in dflow.code_gen) ContainerExecutor (class in dflow) (class in dflow.executor) ContainerOPTemplate (class in dflow.op_template) Context (class in dflow) (class in dflow.context) convert_dflow_list() (in module dflow.utils) convert_to_argo() (dflow.DAG method) (dflow.dag.DAG method) (dflow.HookStep method) (dflow.InputArtifact method) (dflow.InputParameter method) (dflow.Inputs method) (dflow.io.InputArtifact method) (dflow.io.InputParameter method) (dflow.io.Inputs method) (dflow.io.OutputArtifact method) (dflow.io.OutputParameter method) (dflow.io.Outputs method) (dflow.op_template.ScriptOPTemplate method) (dflow.OutputArtifact method) (dflow.OutputParameter method) (dflow.Outputs method) (dflow.python.python_op_template.PythonOPTemplate method) (dflow.python.PythonOPTemplate method) (dflow.Step method) (dflow.step.ArgoSequence method) (dflow.step.HookStep method) (dflow.step.Step method) (dflow.Steps method) (dflow.steps.Steps method) (dflow.Task method) (dflow.task.Task method) (dflow.Workflow method) (dflow.workflow.Workflow method) convert_to_argo_artifact() (dflow.io.OutputParameter method) (dflow.OutputParameter method) convert_to_argo_parameter() (dflow.io.OutputParameter method) (dflow.OutputParameter method) convert_to_graph() (dflow.AutonamedDict method) (dflow.DAG method) (dflow.dag.DAG method) (dflow.InputArtifact method) (dflow.InputParameter method) (dflow.Inputs method) (dflow.io.AutonamedDict method) (dflow.io.InputArtifact method) (dflow.io.InputParameter method) (dflow.io.Inputs method) (dflow.io.OutputArtifact method) (dflow.io.OutputParameter method) (dflow.io.Outputs method) (dflow.op_template.ScriptOPTemplate method) (dflow.OutputArtifact method) (dflow.OutputParameter method) (dflow.Outputs method) (dflow.python.OP class method) (dflow.python.op.OP class method) (dflow.python.python_op_template.PythonOPTemplate method) (dflow.python.PythonOPTemplate method) (dflow.Step method) (dflow.step.Step method) (dflow.Steps method) (dflow.steps.Steps method) (dflow.Task method) (dflow.task.Task method)

convert_value_to_str() (in module dflow.io) copy() (dflow.DAG method) (dflow.dag.DAG method) (dflow.op_template.OPTemplate method) (dflow.OPTemplate method) (dflow.plugins.bohrium.TiefblueClient method) (dflow.Steps method) (dflow.steps.Steps method) (dflow.utils.MinioClient method) (dflow.utils.StorageClient method) copy_artifact() (in module dflow) (in module dflow.utils) copy_file() (in module dflow.utils) copy_results() (in module dflow.python.utils) copy_results_and_return_path_item() (in module dflow.python.utils) copy_s3() (in module dflow) (in module dflow.utils) create_job_group() (in module dflow.plugins.bohrium) create_slice_dir (dflow.python.OP attribute) (dflow.python.op.OP attribute) CustomArtifact (class in dflow) (class in dflow.common) CustomHandler (class in dflow.common) CustomPickler (class in dflow.common)

D

DAG (class in dflow) (class in dflow.dag) dataset (dflow.python.opio.HDF5Dataset property) DatasetsArtifact (class in dflow.plugins.datasets) deduplicate_templates() (dflow.Workflow method) (dflow.workflow.Workflow method) deepcopy() (dflow.op_template.OPTemplate method) (dflow.OPTemplate method) delete() (dflow.Workflow method) (dflow.workflow.Workflow method) delete_pod() (dflow.argo_objects.ArgoStep method) (dflow.ArgoStep method) dflow module dflow.argo_objects module dflow.code_gen module dflow.common module dflow.config module dflow.context module dflow.context_syntax module dflow.dag module dflow.executor module dflow.io module dflow.main module dflow.op_template module dflow.plugins module dflow.plugins.bohrium module dflow.plugins.datasets module dflow.plugins.dispatcher module dflow.plugins.lebesgue module dflow.plugins.ray module dflow.python module

dflow.python.op module dflow.python.opio module dflow.python.python_op_template module dflow.python.utils module dflow.resource module dflow.slurm module dflow.step module dflow.steps module dflow.task module dflow.util_ops module dflow.utils module dflow.workflow module dict2list() (in module dflow.utils) DispatcherArtifact (class in dflow.plugins.dispatcher) DispatcherExecutor (class in dflow.plugins.dispatcher) DockerSecret (class in dflow) (class in dflow.workflow) download() (dflow.common.CustomArtifact method) (dflow.common.HTTPArtifact method) (dflow.common.S3Artifact method) (dflow.CustomArtifact method) (dflow.executor.RemoteExecutor method) (dflow.HTTPArtifact method) (dflow.plugins.bohrium.BohriumDatasetsArtifact method) (dflow.plugins.bohrium.TiefblueClient method) (dflow.plugins.datasets.DatasetsArtifact method) (dflow.RemoteExecutor method) (dflow.S3Artifact method) (dflow.utils.MinioClient method) (dflow.utils.StorageClient method) download_artifact() (in module dflow) (in module dflow.utils) download_artifact_debug() (in module dflow.step) download_s3() (in module dflow) (in module dflow.utils) download_with_lock() (in module dflow.step) dumps() (dflow.common.CustomPickler method)

E

eval() (dflow.io.Expression method) eval_expr() (in module dflow.step) evalable_repr() (dflow.common.S3Artifact method) (dflow.python.python_op_template.Slices method) (dflow.python.Slices method) (dflow.S3Artifact method) (dflow.step.ArgoSequence method) (dflow.utils.Variable method) (in module dflow.utils) exec() (dflow.Step method) (dflow.step.Step method) exec_pod() (dflow.Step method) (dflow.step.Step method) exec_sign_check() (dflow.python.OP static method) (dflow.python.op.OP static method) exec_steps() (dflow.Step method) (dflow.step.Step method)

exec_with_config() (dflow.Step method) (dflow.step.Step method) execute() (dflow.executor.RemoteExecutor method) (dflow.python.OP method) (dflow.python.op.OP method) (dflow.RemoteExecutor method) Executor (class in dflow) (class in dflow.executor) expand() (in module dflow.utils) expr (dflow.Step property) (dflow.step.Step property) (dflow.Task property) (dflow.task.Task property) expr_as_artifact() (dflow.io.OutputParameter method) (dflow.OutputParameter method) expr_as_parameter() (dflow.io.OutputParameter method) (dflow.OutputParameter method) Expression (class in dflow.io)

F

failure_condition (dflow.Resource attribute) (dflow.resource.Resource attribute) FatalError, [1] find_subclass() (in module dflow.utils) flatten() (dflow.common.CustomHandler method) (in module dflow.utils) fnva() (in module dflow.argo_objects) force_link() (in module dflow.utils) force_move() (in module dflow.utils) format_print_table() (in module dflow.main) format_time_delta() (in module dflow.main) from_dict() (dflow.common.S3Artifact class method) (dflow.DAG class method) (dflow.dag.DAG class method) (dflow.InputArtifact class method) (dflow.InputParameter class method) (dflow.Inputs class method) (dflow.io.InputArtifact class method) (dflow.io.InputParameter class method) (dflow.io.Inputs class method) (dflow.io.OutputArtifact class method) (dflow.io.OutputParameter class method) (dflow.io.Outputs class method) (dflow.op_template.ContainerOPTemplate class method) (dflow.op_template.OPTemplate class method) (dflow.op_template.ScriptOPTemplate class method) (dflow.OPTemplate class method) (dflow.OutputArtifact class method) (dflow.OutputParameter class method) (dflow.Outputs class method) (dflow.python.Artifact class method) (dflow.python.BigParameter class method) (dflow.python.opio.Artifact class method) (dflow.python.opio.BigParameter class method) (dflow.python.opio.Parameter class method) (dflow.python.Parameter class method) (dflow.S3Artifact class method) (dflow.Step class method) (dflow.step.ArgoSequence class method) (dflow.step.Step class method) (dflow.Steps class method) (dflow.steps.Steps class method) (dflow.Task class method) (dflow.task.Task class method) (dflow.Workflow class method) (dflow.workflow.Workflow class method)

from_graph() (dflow.DAG class method) (dflow.dag.DAG class method) (dflow.InputArtifact class method) (dflow.InputParameter class method) (dflow.Inputs class method) (dflow.io.InputArtifact class method) (dflow.io.InputParameter class method) (dflow.io.Inputs class method) (dflow.io.OutputArtifact class method) (dflow.io.OutputParameter class method) (dflow.io.Outputs class method) (dflow.op_template.ScriptOPTemplate class method) (dflow.OutputArtifact class method) (dflow.OutputParameter class method) (dflow.Outputs class method) (dflow.python.OP class method) (dflow.python.op.OP class method) (dflow.python.python_op_template.PythonOPTemplate class method) (dflow.python.PythonOPTemplate class method) (dflow.Step class method) (dflow.step.Step class method) (dflow.Steps class method) (dflow.steps.Steps class method) (dflow.Workflow class method) (dflow.workflow.Workflow class method) from_graph_json() (dflow.Workflow class method) (dflow.workflow.Workflow class method) from_graph_yaml() (dflow.Workflow class method) (dflow.workflow.Workflow class method) from_json() (dflow.Workflow class method) (dflow.workflow.Workflow class method) from_rclone_config() (dflow.plugins.datasets.DatasetsArtifact class method) from_urn() (dflow.common.CustomArtifact static method) (dflow.CustomArtifact static method) (dflow.plugins.bohrium.BohriumDatasetsArtifact class method) (dflow.plugins.datasets.DatasetsArtifact class method) from_yaml() (dflow.Workflow class method) (dflow.workflow.Workflow class method) function() (dflow.python.OP class method) (dflow.python.op.OP class method)

G

gen_code() (in module dflow) (in module dflow.code_gen) generate() (dflow.code_gen.CodeGenerator method) get_argo_api_client() (in module dflow.workflow) get_artifact_metadata() (dflow.common.LineageClient method) (dflow.LineageClient method) get_bohrium_urn() (dflow.plugins.datasets.DatasetsArtifact method) get_current_range_param_name() (dflow.context_syntax.Range_Context method) get_data() (dflow.python.opio.HDF5Dataset method) get_duration() (dflow.argo_objects.ArgoStep method) (dflow.argo_objects.ArgoWorkflow method) (dflow.ArgoStep method) (dflow.ArgoWorkflow method) (in module dflow.argo_objects) get_graph_templates() (dflow.Workflow method) (dflow.workflow.Workflow method) get_hash() (in module dflow.argo_objects) get_info() (dflow.python.OP class method) (dflow.python.op.OP class method) get_input_artifact_link() (dflow.python.OP method) (dflow.python.op.OP method) get_input_artifact_storage_key() (dflow.python.OP method) (dflow.python.op.OP method) get_input_sign() (dflow.python.OP class method) (dflow.python.op.OP class method) get_input_slices() (in module dflow.python.utils) get_k8s_client() (in module dflow.op_template) get_k8s_core_v1_api() (dflow.Workflow method) (dflow.workflow.Workflow method) get_key() (in module dflow.utils) get_kwargs() (dflow.code_gen.CodeGenerator method) get_manifest() (dflow.Resource method) (dflow.resource.Resource method) (dflow.slurm.SlurmJob method) (dflow.SlurmJob method) get_md5() (dflow.plugins.bohrium.TiefblueClient method) (dflow.utils.MinioClient method) (dflow.utils.StorageClient method) (in module dflow.utils)

get_mount_script() (dflow.plugins.datasets.DatasetsArtifact method) get_opio_info() (dflow.python.OP class method) (dflow.python.op.OP class method) get_output_artifact_link() (dflow.python.OP method) (dflow.python.op.OP method) get_output_artifact_storage_key() (dflow.python.OP method) (dflow.python.op.OP method) get_output_sign() (dflow.python.OP class method) (dflow.python.op.OP class method) get_path_list_parameter() (dflow.InputArtifact method) (dflow.io.InputArtifact method) (dflow.io.OutputArtifact method) (dflow.OutputArtifact method) get_pod() (dflow.argo_objects.ArgoStep method) (dflow.ArgoStep method) get_pod_name() (in module dflow.argo_objects) get_script() (dflow.argo_objects.ArgoStep method) (dflow.ArgoStep method) (dflow.executor.RemoteExecutor method) (dflow.RemoteExecutor method) get_slices() (dflow.python.python_op_template.PythonOPTemplate method) (dflow.python.PythonOPTemplate method) (in module dflow.python.utils) get_source_code() (in module dflow.python.op) get_step() (dflow.argo_objects.ArgoWorkflow method) (dflow.ArgoWorkflow method) get_sub_nodes() (dflow.argo_objects.ArgoWorkflow method) (dflow.ArgoWorkflow method) get_token() (dflow.plugins.bohrium.TiefblueClient method) get_urn() (dflow.common.CustomArtifact method) (dflow.CustomArtifact method) (dflow.plugins.bohrium.BohriumDatasetsArtifact method) (dflow.plugins.datasets.DatasetsArtifact method) get_urn_parameter() (dflow.InputArtifact method) (dflow.io.InputArtifact method) (dflow.io.OutputArtifact method) (dflow.OutputArtifact method) get_var() (in module dflow.step) get_var_name() (dflow.code_gen.CodeGenerator method)

H

handle_big_parameters() (dflow.argo_objects.ArgoStep method) (dflow.ArgoStep method) handle_empty_dir() (in module dflow.python.utils) handle_input_artifact() (in module dflow.python.utils) handle_input_parameter() (in module dflow.python.utils) handle_io() (dflow.argo_objects.ArgoStep method) (dflow.ArgoStep method) handle_key() (dflow.op_template.OPTemplate method) (dflow.OPTemplate method) handle_lineage() (in module dflow.python.utils) handle_output_artifact() (in module dflow.python.utils) handle_output_parameter() (in module dflow.python.utils) handle_outputs() (dflow.python.OP method) (dflow.python.op.OP method) handle_packages_script() (in module dflow.python.python_op_template) handle_path_list() (dflow.io.OutputArtifact method) (dflow.OutputArtifact method) handle_reused_artifact() (dflow.Workflow method) (dflow.workflow.Workflow method)

handle_reused_artifact_with_copy() (dflow.Workflow method) (dflow.workflow.Workflow method) handle_reused_step() (dflow.Workflow method) (dflow.workflow.Workflow method) handle_sub_path_slices_of_artifact_list() (dflow.Step method) (dflow.step.Step method) handle_template() (dflow.Workflow method) (dflow.workflow.Workflow method) handle_urn() (dflow.io.OutputArtifact method) (dflow.OutputArtifact method) HDF5Dataset (class in dflow.python.opio) HDF5Datasets (class in dflow.python) (class in dflow.python.opio) HookStep (class in dflow) (class in dflow.step) HTTPArtifact (class in dflow) (class in dflow.common)

I

if_expression() (in module dflow) (in module dflow.io) IfExpression (class in dflow) (class in dflow.io) import_func() (in module dflow.common) in_context (dflow.context_syntax.Range_Context property) InitArtifactForSlices (class in dflow.util_ops) InputArtifact (class in dflow) (class in dflow.io)

InputArtifacts (class in dflow.io) InputParameter (class in dflow) (class in dflow.io) InputParameters (class in dflow.io) Inputs (class in dflow) (class in dflow.io) is_none() (dflow.python.opio.HDF5Dataset method) is_str (dflow.io.ArgoVar attribute)

K

key (dflow.python.OP attribute) (dflow.python.op.OP attribute)

L

LebesgueContext (class in dflow.plugins.lebesgue) LebesgueExecutor (class in dflow.plugins.lebesgue) LineageClient (class in dflow) (class in dflow.common) link() (in module dflow.utils) linktree() (in module dflow.utils) list() (dflow.plugins.bohrium.TiefblueClient method) (dflow.utils.MinioClient method) (dflow.utils.StorageClient method)

load_output_artifacts() (dflow.Step method) (dflow.step.Step method) load_output_parameters() (dflow.Step method) (dflow.step.Step method) loads() (dflow.common.CustomPickler method) LocalArtifact (class in dflow) (class in dflow.common) login() (dflow.plugins.bohrium.BohriumContext method) (dflow.plugins.lebesgue.LebesgueContext method) (in module dflow.plugins.bohrium)

M

main() (in module dflow.main) main_parser() (in module dflow.main) match() (in module dflow.argo_objects) merge_dir() (in module dflow.utils) MinioClient (class in dflow.utils) mkdir_and_download() (dflow.executor.RemoteExecutor method) (dflow.RemoteExecutor method) modify_config() (dflow.plugins.bohrium.BohriumDatasetsArtifact method) (dflow.plugins.datasets.DatasetsArtifact method) (dflow.plugins.dispatcher.DispatcherArtifact method) modify_output_artifact() (dflow.argo_objects.ArgoStep method) (dflow.ArgoStep method) modify_output_parameter() (dflow.argo_objects.ArgoStep method) (dflow.ArgoStep method) modify_step() (dflow.plugins.dispatcher.DispatcherExecutor method) module dflow dflow.argo_objects dflow.code_gen dflow.common dflow.config dflow.context dflow.context_syntax dflow.dag dflow.executor dflow.io dflow.main dflow.op_template dflow.plugins dflow.plugins.bohrium dflow.plugins.datasets dflow.plugins.dispatcher dflow.plugins.lebesgue dflow.plugins.ray dflow.python dflow.python.op dflow.python.opio dflow.python.python_op_template dflow.python.utils dflow.resource dflow.slurm dflow.step dflow.steps dflow.task dflow.util_ops dflow.utils dflow.workflow

N

NestedDictBase (class in dflow.python.opio) NestedDictPath (class in dflow.python.opio)

NestedDictStr (class in dflow.python.opio) nullable() (in module dflow.config)

O

ObjectDict (class in dflow.io) OP (class in dflow.python) (class in dflow.python.op) OPIO (class in dflow.python) (class in dflow.python.opio) OPIOSign (class in dflow.python) (class in dflow.python.opio) OPTemplate (class in dflow) (class in dflow.op_template) oss() (dflow.common.S3Artifact method) (dflow.S3Artifact method)

OutputArtifact (class in dflow) (class in dflow.io) OutputArtifacts (class in dflow.io) OutputParameter (class in dflow) (class in dflow.io) OutputParameters (class in dflow.io) Outputs (class in dflow) (class in dflow.io) outputs (dflow.python.OP attribute) (dflow.python.op.OP attribute)

P

Parameter (class in dflow.python) (class in dflow.python.opio) parse_args() (in module dflow.main) parse_repo() (in module dflow.workflow) path_list_of_artifact() (in module dflow) (in module dflow.utils) path_object_of_artifact() (in module dflow) (in module dflow.utils) path_or_none() (in module dflow.python.utils) PicklableFunctionOP (class in dflow.python.python_op_template) pool_size (dflow.python.OP attribute) (dflow.python.op.OP attribute) prepare_argo_arguments() (dflow.Step method) (dflow.step.Step method)

ProcessPoolExecutor (class in dflow.utils) progress_current (dflow.python.OP attribute) (dflow.python.op.OP attribute) progress_total (dflow.python.OP attribute) (dflow.python.op.OP attribute) PVC (class in dflow.io) pvc() (dflow.io.OutputArtifact method) (dflow.OutputArtifact method) PythonOPTemplate (class in dflow.python) (class in dflow.python.python_op_template) PythonScriptOPTemplate (class in dflow) (class in dflow.op_template)

Q

query() (dflow.Workflow method) (dflow.workflow.Workflow method) query_archived_workflows() (in module dflow) (in module dflow.workflow) query_global_outputs() (dflow.Workflow method) (dflow.workflow.Workflow method) query_keys_of_steps() (dflow.Workflow method) (dflow.workflow.Workflow method)

query_status() (dflow.Workflow method) (dflow.workflow.Workflow method) query_step() (dflow.Workflow method) (dflow.workflow.Workflow method) query_step_by_key() (dflow.Workflow method) (dflow.workflow.Workflow method) query_workflows() (in module dflow) (in module dflow.workflow)

R

randstr() (in module dflow) (in module dflow.utils) Range_Context (class in dflow.context_syntax) RayClusterExecutor (class in dflow.plugins.ray) record_generation() (dflow.argo_objects.ArgoWorkflow method) (dflow.ArgoWorkflow method) record_input_artifacts() (dflow.Step method) (dflow.step.Step method) record_input_parameters() (dflow.Step method) (dflow.step.Step method) record_output_artifacts() (dflow.Step method) (dflow.step.Step method) record_output_parameters() (dflow.Step method) (dflow.step.Step method) recover() (dflow.argo_objects.ArgoObjectDict method) (dflow.argo_objects.ArgoObjectList method) (dflow.python.opio.HDF5Dataset method) redirect (dflow.common.CustomArtifact attribute) (dflow.CustomArtifact attribute) register_artifact() (dflow.common.LineageClient method) (dflow.LineageClient method) register_output_artifact() (dflow.python.OP method) (dflow.python.op.OP method) register_task() (dflow.common.LineageClient method) (dflow.LineageClient method) register_workflow() (dflow.common.LineageClient method) (dflow.LineageClient method) remote_download() (dflow.plugins.bohrium.BohriumDatasetsArtifact method) (dflow.plugins.datasets.DatasetsArtifact method) (dflow.plugins.dispatcher.DispatcherArtifact method) RemoteExecutor (class in dflow) (class in dflow.executor) remove_empty_dir_tag() (in module dflow.utils) render() (dflow.common.CustomArtifact method) (dflow.ContainerExecutor method) (dflow.Context method) (dflow.context.Context method) (dflow.CustomArtifact method) (dflow.Executor method) (dflow.executor.ContainerExecutor method) (dflow.executor.Executor method) (dflow.executor.RemoteExecutor method) (dflow.plugins.bohrium.BohriumContext method) (dflow.plugins.bohrium.BohriumExecutor method) (dflow.plugins.datasets.DatasetsArtifact method) (dflow.plugins.dispatcher.DispatcherExecutor method) (dflow.plugins.lebesgue.LebesgueContext method) (dflow.plugins.lebesgue.LebesgueExecutor method) (dflow.plugins.ray.RayClusterExecutor method) (dflow.RemoteExecutor method) (dflow.slurm.SlurmJobTemplate method) (dflow.slurm.SlurmRemoteExecutor method) (dflow.SlurmJobTemplate method) (dflow.SlurmRemoteExecutor method)

render_by_executor() (dflow.Step method) (dflow.step.Step method) render_dag() (dflow.code_gen.CodeGenerator method) render_expr() (in module dflow.step) render_item() (in module dflow.step) render_python_op_template() (dflow.code_gen.CodeGenerator method) render_script() (dflow.python.python_op_template.PythonOPTemplate method) (dflow.python.PythonOPTemplate method) (dflow.util_ops.InitArtifactForSlices method) (in module dflow.step) render_script_op_template() (dflow.code_gen.CodeGenerator method) render_script_with_tmp_root() (in module dflow.executor) render_slices() (dflow.python.python_op_template.PythonOPTemplate method) (dflow.python.PythonOPTemplate method) render_steps() (dflow.code_gen.CodeGenerator method) replace_argo_func() (in module dflow.step) replay() (dflow.argo_objects.ArgoStep method) (dflow.ArgoStep method) repr_as_artifact() (dflow.io.OutputParameter method) (dflow.OutputParameter method) repr_as_parameter() (dflow.io.OutputParameter method) (dflow.OutputParameter method) resolve() (dflow.DAG method) (dflow.dag.DAG method) Resource (class in dflow) (class in dflow.resource) restore() (dflow.common.CustomHandler method) resubmit() (dflow.Workflow method) (dflow.workflow.Workflow method) resume() (dflow.Workflow method) (dflow.workflow.Workflow method) retry() (dflow.argo_objects.ArgoStep method) (dflow.ArgoStep method) (dflow.Workflow method) (dflow.workflow.Workflow method) retry_steps() (dflow.Workflow method) (dflow.workflow.Workflow method) run() (dflow.DAG method) (dflow.dag.DAG method) (dflow.executor.RemoteExecutor method) (dflow.RemoteExecutor method) (dflow.slurm.SlurmRemoteExecutor method) (dflow.SlurmRemoteExecutor method) (dflow.Step method) (dflow.step.Step method) (dflow.Steps method) (dflow.steps.Steps method) run_command() (in module dflow.utils) run_script() (in module dflow.executor) run_with_config() (dflow.Step method) (dflow.step.Step method)

S

S3Artifact (class in dflow) (class in dflow.common) ScriptOPTemplate (class in dflow.op_template) Secret (class in dflow) (class in dflow.op_template) set_artifacts() (dflow.Step method) (dflow.step.Step method) (dflow.Task method) (dflow.task.Task method) set_config() (in module dflow) (in module dflow.config) set_directory() (in module dflow.utils) set_key() (in module dflow.utils) set_output() (dflow.python.OP method) (dflow.python.op.OP method) set_parameters() (dflow.Step method) (dflow.step.Step method) (dflow.Task method) (dflow.task.Task method) set_s3_config() (in module dflow) (in module dflow.config) set_script() (dflow.argo_objects.ArgoStep method) (dflow.ArgoStep method) set_skip_slice_input() (dflow.python.python_op_template.PythonOPTemplate method) (dflow.python.PythonOPTemplate method) set_slices() (dflow.python.python_op_template.PythonOPTemplate method) (dflow.python.PythonOPTemplate method) set_step() (dflow.AutonamedDict method) (dflow.Inputs method) (dflow.io.AutonamedDict method) (dflow.io.Inputs method) (dflow.io.Outputs method) (dflow.Outputs method) set_template() (dflow.AutonamedDict method) (dflow.Inputs method) (dflow.io.AutonamedDict method) (dflow.io.InputArtifacts method) (dflow.io.Inputs method) (dflow.io.OutputArtifacts method) (dflow.io.Outputs method) (dflow.Outputs method)

ShellOPTemplate (class in dflow) (class in dflow.op_template) sigalrm_handler() (in module dflow.python.utils) slice_to_dir() (in module dflow.python.utils) Slices (class in dflow.python) (class in dflow.python.python_op_template) slices (dflow.python.OP attribute) (dflow.python.op.OP attribute) SlurmJob (class in dflow) (class in dflow.slurm) SlurmJobTemplate (class in dflow) (class in dflow.slurm) SlurmRemoteExecutor (class in dflow) (class in dflow.slurm) split_headers() (in module dflow.config) Step (class in dflow) (class in dflow.step) Steps (class in dflow) (class in dflow.steps) stop() (dflow.Workflow method) (dflow.workflow.Workflow method) StorageClient (class in dflow.utils) sub_path() (dflow.common.LocalArtifact method) (dflow.common.S3Artifact method) (dflow.InputArtifact method) (dflow.io.InputArtifact method) (dflow.io.OutputArtifact method) (dflow.LocalArtifact method) (dflow.OutputArtifact method) (dflow.plugins.bohrium.BohriumDatasetsArtifact method) (dflow.plugins.datasets.DatasetsArtifact method) (dflow.S3Artifact method) subclass_or_none() (in module dflow.utils) submit() (dflow.Workflow method) (dflow.workflow.Workflow method) success_condition (dflow.Resource attribute) (dflow.resource.Resource attribute) superfunction() (dflow.python.OP class method) (dflow.python.op.OP class method) suspend() (dflow.Workflow method) (dflow.workflow.Workflow method)

T

t (in module dflow.python.opio) Task (class in dflow) (class in dflow.task) terminate() (dflow.Workflow method) (dflow.workflow.Workflow method) TiefblueClient (class in dflow.plugins.bohrium) tmp_root (dflow.python.OP attribute) (dflow.python.op.OP attribute) to_dict() (dflow.common.S3Artifact method) (dflow.plugins.bohrium.TiefblueClient method) (dflow.python.Artifact method) (dflow.python.BigParameter method) (dflow.python.opio.Artifact method) (dflow.python.opio.BigParameter method) (dflow.python.opio.Parameter method) (dflow.python.Parameter method) (dflow.S3Artifact method) (dflow.step.ArgoSequence method) (dflow.Workflow method) (dflow.workflow.Workflow method)

to_expr() (in module dflow.io) to_graph() (dflow.Workflow method) (dflow.workflow.Workflow method) to_graph_json() (dflow.Workflow method) (dflow.workflow.Workflow method) to_graph_yaml() (dflow.Workflow method) (dflow.workflow.Workflow method) to_in_context() (dflow.context_syntax.Range_Context method) to_json() (dflow.Workflow method) (dflow.workflow.Workflow method) to_out_context() (dflow.context_syntax.Range_Context method) to_yaml() (dflow.Workflow method) (dflow.workflow.Workflow method) TransientError, [1] try_link() (in module dflow.utils) try_to_execute() (in module dflow.python.utils) type2opiosign() (in module dflow.python.op) type_to_str() (in module dflow.io)

U

update_dict() (in module dflow.plugins.dispatcher) update_headers() (in module dflow.plugins.bohrium) upload() (dflow.executor.RemoteExecutor method) (dflow.plugins.bohrium.TiefblueClient method) (dflow.RemoteExecutor method) (dflow.utils.MinioClient method) (dflow.utils.StorageClient method)

upload_artifact() (in module dflow) (in module dflow.utils) upload_if_exists() (dflow.executor.RemoteExecutor method) (dflow.RemoteExecutor method) upload_python_packages() (in module dflow.step) upload_s3() (in module dflow) (in module dflow.utils)

V

Variable (class in dflow.utils)

W

wait() (dflow.Workflow method) (dflow.workflow.Workflow method) wait_for_mount() (in module dflow.plugins.datasets)

Workflow (class in dflow) (class in dflow.workflow) workflow_name (dflow.python.OP attribute) (dflow.python.op.OP attribute)