Library API (application programmer interface)
The Pydra workflow engine.
Pydra is a rewrite of the Nipype engine with mapping and joining as first-class operations. It forms the core of the Nipype 2.0 ecosystem.
- pydra.check_latest_version()
- pydra.set_input_validator(flag=False)
Subpackages
- pydra.engine package
AuditFlagDockerTaskShellCommandTaskSubmitterWorkflow- Submodules
- pydra.engine.audit module
- pydra.engine.boutiques module
- pydra.engine.core module
TaskBaseTaskBase.audit_flagsTaskBase.cache_dirTaskBase.cache_locationsTaskBase.can_resumeTaskBase.checksumTaskBase.checksum_states()TaskBase.combine()TaskBase.cont_dimTaskBase.doneTaskBase.erroredTaskBase.generated_output_namesTaskBase.get_input_el()TaskBase.help()TaskBase.output_dirTaskBase.output_namesTaskBase.pickle_task()TaskBase.result()TaskBase.set_state()TaskBase.split()TaskBase.uidTaskBase.version
Workflowis_lazy()is_task()is_workflow()
- pydra.engine.graph module
DiGraphDiGraph.add_edges()DiGraph.add_edges_description()DiGraph.add_nodes()DiGraph.calculate_max_paths()DiGraph.copy()DiGraph.create_dotfile_detailed()DiGraph.create_dotfile_nested()DiGraph.create_dotfile_simple()DiGraph.edgesDiGraph.edges_namesDiGraph.export_graph()DiGraph.nodesDiGraph.nodes_detailsDiGraph.nodes_names_mapDiGraph.remove_nodes()DiGraph.remove_nodes_connections()DiGraph.remove_previous_connections()DiGraph.remove_successors_nodes()DiGraph.sorted_nodesDiGraph.sorted_nodes_namesDiGraph.sorting()
- pydra.engine.helpers module
PydraFileLockargstr_formatting()copyfile_workflow()create_checksum()custom_validator()ensure_list()execute()gather_runtime_info()get_available_cpus()get_open_loop()hash_function()hash_value()load_and_run()load_and_run_async()load_result()load_task()make_klass()output_from_inputfields()position_sort()print_help()read_and_display()read_and_display_async()read_stream_and_display()record_error()save()task_hash()
- pydra.engine.helpers_file module
- pydra.engine.helpers_state module
- pydra.engine.specs module
- pydra.engine.state module
StateState.nameState.splitterState.splitter_rpn_compactState.splitter_rpnState.combinerState.splitter_finalState.other_statesState.inner_inputsState.states_indState.states_valState.inputs_indState.group_for_inputsState.group_for_inputs_finalState.groups_stack_finalState.final_combined_ind_mappingState.combinerState.combiner_validation()State.current_combinerState.current_combiner_allState.current_splitterState.current_splitter_rpnState.inner_inputsState.other_statesState.prepare_inputs()State.prepare_states()State.prepare_states_combined_ind()State.prepare_states_ind()State.prepare_states_val()State.prev_state_combinerState.prev_state_combiner_allState.prev_state_splitterState.prev_state_splitter_rpnState.prev_state_splitter_rpn_compactState.set_input_groups()State.splits()State.splitterState.splitter_finalState.splitter_rpnState.splitter_rpn_compactState.splitter_rpn_finalState.splitter_validation()State.update_connections()
- pydra.engine.submitter module
- pydra.engine.task module
- pydra.engine.workers module
- pydra.mark package
- pydra.tasks package
- pydra.utils package