fastr Package¶
fastr
Package¶
Initialize self. See help(type(self)) for accurate signature.
- fastr.__init__.__format__()¶
default object formatter
- fastr.__init__.__init_subclass__()¶
This method is called when a class is subclassed.
The default implementation does nothing. It may be overridden to extend subclasses.
- fastr.__init__.__new__(*args, **kwargs)¶
Create and return a new object. See help(type) for accurate signature.
- fastr.__init__.__reduce__()¶
helper for pickle
- fastr.__init__.__reduce_ex__()¶
helper for pickle
- fastr.__init__.__subclasshook__()¶
Abstract classes can override this to customize issubclass().
This is invoked early on by abc.ABCMeta.__subclasscheck__(). It should return True, False or NotImplemented. If it returns NotImplemented, the normal algorithm is used. Otherwise, it overrides the normal algorithm (and the outcome is cached).
exceptions
Module¶
This module contains all Fastr-related Exceptions
- exception fastr.exceptions.FastrAttributeError(*args, **kwargs)[source]¶
Bases:
FastrError
,AttributeError
AttributeError in the fastr system
- __module__ = 'fastr.exceptions'¶
- exception fastr.exceptions.FastrCannotChangeAttributeError(*args, **kwargs)[source]¶
Bases:
FastrError
Attempting to change an attribute of an object that can be set only once.
- __module__ = 'fastr.exceptions'¶
- exception fastr.exceptions.FastrCardinalityError(*args, **kwargs)[source]¶
Bases:
FastrError
The description of the cardinality is not valid.
- __module__ = 'fastr.exceptions'¶
- exception fastr.exceptions.FastrCollectorError(*args, **kwargs)[source]¶
Bases:
FastrError
Cannot collect the results from a Job because of an error
- __module__ = 'fastr.exceptions'¶
- exception fastr.exceptions.FastrDataTypeFileNotReadable(*args, **kwargs)[source]¶
Bases:
FastrError
Could not read the datatype file.
- __module__ = 'fastr.exceptions'¶
- exception fastr.exceptions.FastrDataTypeMismatchError(*args, **kwargs)[source]¶
Bases:
FastrError
When using a DataType as the key for the DataTypeManager, the DataTypeManager found another DataType with the same name already in the DataTypeManager. The means fastr has two version of the same DataType in the system, which should never happen!
- __module__ = 'fastr.exceptions'¶
- exception fastr.exceptions.FastrDataTypeNotAvailableError(*args, **kwargs)[source]¶
Bases:
FastrError
The DataType requested is not found by the fastr system. Typically this means that no matching DataType is found in the DataTypeManager.
- __module__ = 'fastr.exceptions'¶
- exception fastr.exceptions.FastrDataTypeNotInstantiableError(*args, **kwargs)[source]¶
Bases:
FastrError
The base classes for DataTypes cannot be instantiated and should always be sub-classed.
- __module__ = 'fastr.exceptions'¶
- exception fastr.exceptions.FastrDataTypeValueError(*args, **kwargs)[source]¶
Bases:
FastrError
This value in fastr did not pass the validation specificied for its DataType, typically means that the data is missing or corrupt.
- __module__ = 'fastr.exceptions'¶
- exception fastr.exceptions.FastrError(*args, **kwargs)[source]¶
Bases:
Exception
This is the base class for all fastr related exceptions. Catching this class of exceptions should ensure a proper execution of fastr.
- __init__(*args, **kwargs)[source]¶
Constructor for all exceptions. Saves the caller object fullid (if found) and the file, function and line number where the object was created.
- __module__ = 'fastr.exceptions'¶
- __weakref__¶
list of weak references to the object (if defined)
- exception fastr.exceptions.FastrErrorInSubprocess(*args, **kwargs)[source]¶
Bases:
FastrExecutionError
Encountered an error in the subprocess started by the execution script
- __module__ = 'fastr.exceptions'¶
- exception fastr.exceptions.FastrExecutableNotFoundError(executable=None, *args, **kwargs)[source]¶
Bases:
FastrExecutionError
The executable could not be found!
- __init__(executable=None, *args, **kwargs)[source]¶
Constructor for all exceptions. Saves the caller object fullid (if found) and the file, function and line number where the object was created.
- __module__ = 'fastr.exceptions'¶
- exception fastr.exceptions.FastrExecutionError(*args, **kwargs)[source]¶
Bases:
FastrError
Base class for all fastr execution related errors
- __module__ = 'fastr.exceptions'¶
- exception fastr.exceptions.FastrFileNotFound(filepath, message=None)[source]¶
Bases:
FastrError
Could not find an expected file
- __init__(filepath, message=None)[source]¶
Constructor for all exceptions. Saves the caller object fullid (if found) and the file, function and line number where the object was created.
- __module__ = 'fastr.exceptions'¶
- exception fastr.exceptions.FastrIOError(*args, **kwargs)[source]¶
Bases:
FastrError
,OSError
IOError in the fastr system
- __module__ = 'fastr.exceptions'¶
- __weakref__¶
list of weak references to the object (if defined)
- exception fastr.exceptions.FastrImportError(*args, **kwargs)[source]¶
Bases:
FastrError
,ImportError
ImportError in the fastr system
- __module__ = 'fastr.exceptions'¶
- __weakref__¶
list of weak references to the object (if defined)
- exception fastr.exceptions.FastrIndexError(*args, **kwargs)[source]¶
Bases:
FastrError
,IndexError
IndexError in the fastr system
- __module__ = 'fastr.exceptions'¶
- exception fastr.exceptions.FastrIndexNonexistent(*args, **kwargs)[source]¶
Bases:
FastrIndexError
This is an IndexError for samples requested from a sparse data array. The sample is not there but is probably not there because of sparseness rather than being a missing sample (e.g. out of bounds).
- __module__ = 'fastr.exceptions'¶
- exception fastr.exceptions.FastrKeyError(*args, **kwargs)[source]¶
Bases:
FastrError
,KeyError
KeyError in the fastr system
- __module__ = 'fastr.exceptions'¶
- exception fastr.exceptions.FastrLockNotAcquired(directory, message=None)[source]¶
Bases:
FastrError
Could not lock a directory
- __init__(directory, message=None)[source]¶
Constructor for all exceptions. Saves the caller object fullid (if found) and the file, function and line number where the object was created.
- __module__ = 'fastr.exceptions'¶
- exception fastr.exceptions.FastrLookupError(*args, **kwargs)[source]¶
Bases:
FastrError
Could not find specified object in the fastr environment.
- __module__ = 'fastr.exceptions'¶
- exception fastr.exceptions.FastrMountUnknownError(*args, **kwargs)[source]¶
Bases:
FastrKeyError
Trying to access an undefined mount
- __module__ = 'fastr.exceptions'¶
- exception fastr.exceptions.FastrNetworkMismatchError(*args, **kwargs)[source]¶
Bases:
FastrError
Two interacting objects belong to different fastr network.
- __module__ = 'fastr.exceptions'¶
- exception fastr.exceptions.FastrNetworkUnknownError(*args, **kwargs)[source]¶
Bases:
FastrKeyError
Reference to a Tool that is not recognised by the fastr system. This typically means the specific id/version combination of the requested tool has not been loaded by the ToolManager.
- __module__ = 'fastr.exceptions'¶
- exception fastr.exceptions.FastrNoValidTargetError(*args, **kwargs)[source]¶
Bases:
FastrKeyError
Cannot find a valid target for the tool
- __module__ = 'fastr.exceptions'¶
- exception fastr.exceptions.FastrNodeAreadyPreparedError(*args, **kwargs)[source]¶
Bases:
FastrStateError
A attempt is made at preparing a NodeRun for the second time. This is not allowed as it would wipe the current execution data and cause data-loss.
- __module__ = 'fastr.exceptions'¶
- exception fastr.exceptions.FastrNodeNotPreparedError(*args, **kwargs)[source]¶
Bases:
FastrStateError
When trying to access executation data of a NodeRun, the NodeRun must be prepare. The NodeRun has not been prepared by the execution, so the data is not available!
- __module__ = 'fastr.exceptions'¶
- exception fastr.exceptions.FastrNodeNotValidError(*args, **kwargs)[source]¶
Bases:
FastrStateError
A NodeRun is not in a valid state where it should be, typically an invalid NodeRun is passed to the executor causing trouble.
- __module__ = 'fastr.exceptions'¶
- exception fastr.exceptions.FastrNotExecutableError(*args, **kwargs)[source]¶
Bases:
FastrExecutionError
The command invoked by subprocess is not executable on the system
- __module__ = 'fastr.exceptions'¶
- exception fastr.exceptions.FastrNotImplementedError(*args, **kwargs)[source]¶
Bases:
FastrError
,NotImplementedError
This function/method has not been implemented on purpose (e.g. should be overwritten in a sub-class)
- __module__ = 'fastr.exceptions'¶
- exception fastr.exceptions.FastrOSError(*args, **kwargs)[source]¶
Bases:
FastrError
,OSError
OSError in the fastr system
- __module__ = 'fastr.exceptions'¶
- __weakref__¶
list of weak references to the object (if defined)
- exception fastr.exceptions.FastrObjectUnknownError(*args, **kwargs)[source]¶
Bases:
FastrKeyError
Reference to a Tool that is not recognised by the fastr system. This typically means the specific id/version combination of the requested tool has not been loaded by the ToolManager.
- __module__ = 'fastr.exceptions'¶
- exception fastr.exceptions.FastrOptionalModuleNotAvailableError(*args, **kwargs)[source]¶
Bases:
FastrNotImplementedError
A optional modules for Fastr is needed for this function, but is not available on the current python installation.
- __module__ = 'fastr.exceptions'¶
- exception fastr.exceptions.FastrOutputValidationError(*args, **kwargs)[source]¶
Bases:
FastrExecutionError
An output of a Job does not pass validation
- __module__ = 'fastr.exceptions'¶
- exception fastr.exceptions.FastrParentMismatchError(*args, **kwargs)[source]¶
Bases:
FastrError
Two interactive objects have different parent where they should be the same
- __module__ = 'fastr.exceptions'¶
- exception fastr.exceptions.FastrPluginCapabilityNotImplemented(*args, **kwargs)[source]¶
Bases:
FastrNotImplementedError
A plugin did not implement a capability that it advertised.
- __module__ = 'fastr.exceptions'¶
- exception fastr.exceptions.FastrPluginNotAvailable(*args, **kwargs)[source]¶
Bases:
FastrKeyError
Indicates that a requested Plugin was not found on the system.
- __module__ = 'fastr.exceptions'¶
- exception fastr.exceptions.FastrPluginNotLoaded(*args, **kwargs)[source]¶
Bases:
FastrStateError
The plugin was not successfully loaded. This means the plugin class cannot be instantiated.
- __module__ = 'fastr.exceptions'¶
- exception fastr.exceptions.FastrResultFileNotFound(filepath, message=None)[source]¶
Bases:
FastrFileNotFound
,FastrExecutionError
Could not found the result file of job that finished. This means the executionscript process was killed during interruption. Generally this means a scheduler killed it because of resource shortage.
- __module__ = 'fastr.exceptions'¶
- exception fastr.exceptions.FastrScriptNotFoundError(interpreter=None, script=None, paths=None, *args, **kwargs)[source]¶
Bases:
FastrExecutionError
Script could not be found
- __init__(interpreter=None, script=None, paths=None, *args, **kwargs)[source]¶
Constructor for all exceptions. Saves the caller object fullid (if found) and the file, function and line number where the object was created.
- __module__ = 'fastr.exceptions'¶
- exception fastr.exceptions.FastrSerializationError(message, serializer, original_exception=None)[source]¶
Bases:
FastrError
The serialization encountered a serious problem
- __init__(message, serializer, original_exception=None)[source]¶
Constructor for all exceptions. Saves the caller object fullid (if found) and the file, function and line number where the object was created.
- __module__ = 'fastr.exceptions'¶
- exception fastr.exceptions.FastrSerializationIgnoreDefaultError(message, serializer, original_exception=None)[source]¶
Bases:
FastrSerializationError
The value and default are both None, so the value should not be serialized.
- __module__ = 'fastr.exceptions'¶
- exception fastr.exceptions.FastrSerializationInvalidDataError(message, serializer, original_exception=None)[source]¶
Bases:
FastrSerializationError
Encountered data to serialize that is invalid given the serialization schema.
- __module__ = 'fastr.exceptions'¶
- exception fastr.exceptions.FastrSerializationMethodError(*args, **kwargs)[source]¶
Bases:
FastrKeyError
The desired serialization method does not exist.
- __module__ = 'fastr.exceptions'¶
Bases:
FastrKeyError
Could not find the Sink data for the desire sink.
- exception fastr.exceptions.FastrSizeInvalidError(*args, **kwargs)[source]¶
Bases:
FastrError
The given size cannot be valid.
- __module__ = 'fastr.exceptions'¶
- exception fastr.exceptions.FastrSizeMismatchError(*args, **kwargs)[source]¶
Bases:
FastrError
The size of two object in fastr is not matching where it should.
- __module__ = 'fastr.exceptions'¶
- exception fastr.exceptions.FastrSizeUnknownError(*args, **kwargs)[source]¶
Bases:
FastrError
The size of object is not (yet) known and only a theoretical estimate is available at the moment.
- __module__ = 'fastr.exceptions'¶
Bases:
FastrKeyError
Could not find the Source data for the desire source.
- exception fastr.exceptions.FastrStateError(*args, **kwargs)[source]¶
Bases:
FastrError
An object is in an invalid/unexpected state.
- __module__ = 'fastr.exceptions'¶
- exception fastr.exceptions.FastrSubprocessNotFinished(*args, **kwargs)[source]¶
Bases:
FastrExecutionError
Encountered an error before the subprocess call by the execution script was properly finished.
- __module__ = 'fastr.exceptions'¶
- exception fastr.exceptions.FastrToolNotAvailableError(*args, **kwargs)[source]¶
Bases:
FastrError
- The tool used is not available on the current platform (OS and architecture
combination) and cannot be used.
- __module__ = 'fastr.exceptions'¶
- exception fastr.exceptions.FastrToolTargetNotFound(*args, **kwargs)[source]¶
Bases:
FastrError
Could not determine the location of the tools target binary/script. The tool cannot be used.
- __module__ = 'fastr.exceptions'¶
- exception fastr.exceptions.FastrToolUnknownError(*args, **kwargs)[source]¶
Bases:
FastrKeyError
Reference to a Tool that is not recognised by the fastr system. This typically means the specific id/version combination of the requested tool has not been loaded by the ToolManager.
- __module__ = 'fastr.exceptions'¶
- exception fastr.exceptions.FastrToolVersionError(*args, **kwargs)[source]¶
Bases:
FastrError
Version mismatch, usually the installed tool version and version requested by the network mismatch.
- __module__ = 'fastr.exceptions'¶
- exception fastr.exceptions.FastrTypeError(*args, **kwargs)[source]¶
Bases:
FastrError
,TypeError
TypeError in the fastr system
- __module__ = 'fastr.exceptions'¶
- exception fastr.exceptions.FastrUnknownURLSchemeError(*args, **kwargs)[source]¶
Bases:
FastrKeyError
Fastr encountered a data URL with a scheme that was not recognised by the IOPlugin manager.
- __module__ = 'fastr.exceptions'¶
- exception fastr.exceptions.FastrValueError(*args, **kwargs)[source]¶
Bases:
FastrError
,ValueError
ValueError in the fastr system
- __module__ = 'fastr.exceptions'¶
- exception fastr.exceptions.FastrVersionInvalidError(*args, **kwargs)[source]¶
Bases:
FastrValueError
The string representation of the version is malformatted.
- __module__ = 'fastr.exceptions'¶
- exception fastr.exceptions.FastrVersionMismatchError(*args, **kwargs)[source]¶
Bases:
FastrValueError
There is a mismatch between different parts of the Fastr environment and integrity is compromised.
- __module__ = 'fastr.exceptions'¶
- fastr.exceptions.get_message(exception)[source]¶
Extract the message from an exception is a safe manner
- Parameters
exception (BaseException) – exception to extract from
- Returns
message string
- Return type
globals
Module¶
- fastr.globals.get_current_run()[source]¶
- Return type
Optional[NetworkRun]
version
Module¶
This module keeps track of the version of the currently used Fastr framework. It can check its version from mercurial or a saved file
Subpackages¶
- api Package
api
PackageResourceLimit
ResourceLimit.__eq__()
ResourceLimit.__getstate__()
ResourceLimit.__hash__
ResourceLimit.__init__()
ResourceLimit.__module__
ResourceLimit.__ne__()
ResourceLimit.__setstate__()
ResourceLimit.__slots__
ResourceLimit.copy()
ResourceLimit.cores
ResourceLimit.gpus
ResourceLimit.memory
ResourceLimit.set_memory_multiplier()
ResourceLimit.time
create_network()
create_network_copy()
- core Package
core
Packagecardinality
ModuleAnyCardinalitySpec
AsCardinalitySpec
AsCardinalitySpec.__eq__()
AsCardinalitySpec.__hash__
AsCardinalitySpec.__init__()
AsCardinalitySpec.__module__
AsCardinalitySpec.__str__()
AsCardinalitySpec.calculate_execution_cardinality()
AsCardinalitySpec.calculate_job_cardinality()
AsCardinalitySpec.calculate_planning_cardinality()
AsCardinalitySpec.get_ordereddict_cardinality()
AsCardinalitySpec.get_target()
AsCardinalitySpec.node
AsCardinalitySpec.predefined
CardinalitySpec
CardinalitySpec.__dict__
CardinalitySpec.__eq__()
CardinalitySpec.__hash__
CardinalitySpec.__init__()
CardinalitySpec.__module__
CardinalitySpec.__ne__()
CardinalitySpec.__repr__()
CardinalitySpec.__str__()
CardinalitySpec.__weakref__
CardinalitySpec.calculate_execution_cardinality()
CardinalitySpec.calculate_job_cardinality()
CardinalitySpec.calculate_planning_cardinality()
CardinalitySpec.predefined
CardinalitySpec.validate()
ChoiceCardinalitySpec
IntCardinalitySpec
IntCardinalitySpec.__eq__()
IntCardinalitySpec.__hash__
IntCardinalitySpec.__init__()
IntCardinalitySpec.__module__
IntCardinalitySpec.__str__()
IntCardinalitySpec.calculate_execution_cardinality()
IntCardinalitySpec.calculate_job_cardinality()
IntCardinalitySpec.calculate_planning_cardinality()
IntCardinalitySpec.predefined
MaxCardinalitySpec
MinCardinalitySpec
RangeCardinalitySpec
ValueCardinalitySpec
create_cardinality()
dimension
Moduleinterface
Moduleioplugin
ModuleIOPlugin
IOPlugin.__abstractmethods__
IOPlugin.__init__()
IOPlugin.__module__
IOPlugin.cleanup()
IOPlugin.expand_url()
IOPlugin.fetch_url()
IOPlugin.fetch_value()
IOPlugin.isurl()
IOPlugin.path_to_url()
IOPlugin.print_result()
IOPlugin.pull_source_data()
IOPlugin.push_sink_data()
IOPlugin.put_url()
IOPlugin.put_value()
IOPlugin.scheme
IOPlugin.setup()
IOPlugin.url_to_path()
provenance
ModuleProvenance
Provenance.__dict__
Provenance.__init__()
Provenance.__module__
Provenance.__weakref__
Provenance.activity()
Provenance.agent()
Provenance.collect_input_argument_provenance()
Provenance.collect_provenance()
Provenance.data_uri()
Provenance.entity()
Provenance.get_parent_provenance()
Provenance.init_provenance()
Provenance.serialize()
resourcelimit
ModuleResourceLimit
ResourceLimit.__annotations__
ResourceLimit.__eq__()
ResourceLimit.__getstate__()
ResourceLimit.__hash__
ResourceLimit.__init__()
ResourceLimit.__module__
ResourceLimit.__ne__()
ResourceLimit.__setstate__()
ResourceLimit.__slots__
ResourceLimit.copy()
ResourceLimit.cores
ResourceLimit.gpus
ResourceLimit.memory
ResourceLimit.set_memory_multiplier()
ResourceLimit.time
samples
ModuleContainsSamples
HasSamples
SampleBaseId
SampleBaseId.__abstractmethods__
SampleBaseId.__add__()
SampleBaseId.__annotations__
SampleBaseId.__args__
SampleBaseId.__dict__
SampleBaseId.__extra__
SampleBaseId.__getnewargs__()
SampleBaseId.__module__
SampleBaseId.__new__()
SampleBaseId.__next_in_mro__
SampleBaseId.__orig_bases__
SampleBaseId.__origin__
SampleBaseId.__parameters__
SampleBaseId.__radd__()
SampleBaseId.__repr__()
SampleBaseId.__str__()
SampleBaseId.__tree_hash__
SampleCollection
SampleCollection.__abstractmethods__
SampleCollection.__contains__()
SampleCollection.__delitem__()
SampleCollection.__dict__
SampleCollection.__getitem__()
SampleCollection.__init__()
SampleCollection.__iter__()
SampleCollection.__len__()
SampleCollection.__module__
SampleCollection.__repr__()
SampleCollection.__setitem__()
SampleCollection.__weakref__
SampleCollection.dimensions
SampleCollection.fullid
SampleCollection.ndims
SampleCollection.parent
SampleId
SampleIndex
SampleIndex.__abstractmethods__
SampleIndex.__args__
SampleIndex.__extra__
SampleIndex.__module__
SampleIndex.__next_in_mro__
SampleIndex.__orig_bases__
SampleIndex.__origin__
SampleIndex.__parameters__
SampleIndex.__repr__()
SampleIndex.__str__()
SampleIndex.__tree_hash__
SampleIndex.expand()
SampleIndex.isslice
SampleItem
SampleItemBase
SampleItemBase.__add__()
SampleItemBase.__dict__
SampleItemBase.__getnewargs__()
SampleItemBase.__module__
SampleItemBase.__new__()
SampleItemBase.__repr__()
SampleItemBase.cardinality
SampleItemBase.combine()
SampleItemBase.data
SampleItemBase.dimensionality
SampleItemBase.failed_annotations
SampleItemBase.id
SampleItemBase.index
SampleItemBase.jobs
SampleItemBase.replace()
SampleItemBase.status
SamplePayload
SampleState
SampleValue
SampleValue.__abstractmethods__
SampleValue.__add__()
SampleValue.__annotations__
SampleValue.__delitem__()
SampleValue.__dict__
SampleValue.__getitem__()
SampleValue.__getstate__()
SampleValue.__init__()
SampleValue.__iter__()
SampleValue.__len__()
SampleValue.__module__
SampleValue.__radd__()
SampleValue.__repr__()
SampleValue.__setitem__()
SampleValue.__setstate__()
SampleValue.__weakref__
SampleValue.cast()
SampleValue.is_mapping
SampleValue.is_sequence
SampleValue.iterelements()
SampleValue.mapping_part()
SampleValue.sequence_part()
target
ModuleProcessUsageCollection
ProcessUsageCollection.__abstractmethods__
ProcessUsageCollection.__dict__
ProcessUsageCollection.__getitem__()
ProcessUsageCollection.__init__()
ProcessUsageCollection.__len__()
ProcessUsageCollection.__module__
ProcessUsageCollection.__weakref__
ProcessUsageCollection.aggregate()
ProcessUsageCollection.append()
ProcessUsageCollection.usage_type
SubprocessBasedTarget
SystemUsageInfo
Target
TargetResult
tool
ModuleTool
Tool.DEFAULT_TARGET_CLASS
Tool.TOOL_REFERENCE_FILE_NAME
Tool.TOOL_RESULT_FILE_NAME
Tool.__dataschemafile__
Tool.__eq__()
Tool.__getstate__()
Tool.__hash__
Tool.__init__()
Tool.__module__
Tool.__repr__()
Tool.__setstate__()
Tool.__str__()
Tool.authors
Tool.cite
Tool.command
Tool.command_version
Tool.compare_output_data()
Tool.create_reference()
Tool.description
Tool.execute()
Tool.fullid
Tool.hash
Tool.help
Tool.id
Tool.inputs
Tool.name
Tool.namespace
Tool.node_class
Tool.ns_id
Tool.outputs
Tool.path
Tool.references
Tool.requirements
Tool.serialize()
Tool.tags
Tool.target
Tool.test()
Tool.test_spec
Tool.test_tool()
Tool.url
Tool.version
version
Modulevfs
ModuleVirtualFileSystem
VirtualFileSystem.__dict__
VirtualFileSystem.__init__()
VirtualFileSystem.__module__
VirtualFileSystem.__weakref__
VirtualFileSystem.abstract
VirtualFileSystem.copy_file_dir()
VirtualFileSystem.expand_network_scope()
VirtualFileSystem.expand_url()
VirtualFileSystem.fetch_url()
VirtualFileSystem.fetch_value()
VirtualFileSystem.path_to_url()
VirtualFileSystem.put_url()
VirtualFileSystem.put_value()
VirtualFileSystem.scheme
VirtualFileSystem.setup()
VirtualFileSystem.url_to_path()
- Subpackages
- data Package
- datatypes Package
datatypes
PackageAnyFile
AnyType
BaseDataType
BaseDataType.__abstractmethods__
BaseDataType.__annotations__
BaseDataType.__eq__()
BaseDataType.__getstate__()
BaseDataType.__hash__
BaseDataType.__init__()
BaseDataType.__module__
BaseDataType.__ne__()
BaseDataType.__reduce_ex__()
BaseDataType.__repr__()
BaseDataType.__setstate__()
BaseDataType.__str__()
BaseDataType.checksum()
BaseDataType.description
BaseDataType.dot_extension
BaseDataType.extension
BaseDataType.filename
BaseDataType.fullid
BaseDataType.id
BaseDataType.isinstance()
BaseDataType.name
BaseDataType.parent
BaseDataType.parsed_value
BaseDataType.raw_value
BaseDataType.test()
BaseDataType.valid
BaseDataType.value
BaseDataType.version
DataType
DataTypeManager
DataTypeManager.__abstractmethods__
DataTypeManager.__args__
DataTypeManager.__extra__
DataTypeManager.__init__()
DataTypeManager.__keytransform__()
DataTypeManager.__module__
DataTypeManager.__next_in_mro__
DataTypeManager.__orig_bases__
DataTypeManager.__origin__
DataTypeManager.__parameters__
DataTypeManager.__subclasshook__()
DataTypeManager.__tree_hash__
DataTypeManager.create_enumtype()
DataTypeManager.fullid
DataTypeManager.get_type()
DataTypeManager.guess_type()
DataTypeManager.has_type()
DataTypeManager.isdatatype()
DataTypeManager.match_types()
DataTypeManager.match_types_any()
DataTypeManager.plugin_class
DataTypeManager.poll_datatype()
DataTypeManager.populate()
DataTypeManager.preferred_types
Deferred
EnumType
Missing
TypeGroup
URLType
ValueType
fastr_isinstance()
- execution Package
execution
Packagebasenoderun
Moduleenvironmentmodules
ModuleEnvironmentModules
EnvironmentModules.__dict__
EnvironmentModules.__init__()
EnvironmentModules.__module__
EnvironmentModules.__repr__()
EnvironmentModules.__weakref__
EnvironmentModules.avail()
EnvironmentModules.avail_modules
EnvironmentModules.clear()
EnvironmentModules.isloaded()
EnvironmentModules.load()
EnvironmentModules.loaded_modules
EnvironmentModules.reload()
EnvironmentModules.swap()
EnvironmentModules.sync()
EnvironmentModules.tostring_modvalue()
EnvironmentModules.totuple_modvalue()
EnvironmentModules.unload()
ModuleSystem
executionscript
Moduleflownoderun
Moduleinputoutputrun
ModuleAdvancedFlowOutputRun
BaseInputRun
InputRun
InputRun.__abstractmethods__
InputRun.__getitem__()
InputRun.__getstate__()
InputRun.__init__()
InputRun.__module__
InputRun.__setstate__()
InputRun.__str__()
InputRun.cardinality()
InputRun.datatype
InputRun.dimensions
InputRun.fullid
InputRun.get_sourced_nodes()
InputRun.get_sourced_outputs()
InputRun.get_subinput_cardinality()
InputRun.index()
InputRun.input_group
InputRun.insert()
InputRun.itersubinputs()
InputRun.remove()
InputRun.source
MacroOutputRun
NamedSubinputRun
OutputRun
OutputRun.__abstractmethods__
OutputRun.__getitem__()
OutputRun.__getstate__()
OutputRun.__init__()
OutputRun.__module__
OutputRun.__setitem__()
OutputRun.__setstate__()
OutputRun.__str__()
OutputRun.automatic
OutputRun.cardinality()
OutputRun.datatype
OutputRun.fullid
OutputRun.iterconvergingindices()
OutputRun.listeners
OutputRun.preferred_types
OutputRun.resulting_datatype
OutputRun.samples
OutputRun.valid
SourceOutputRun
SubInputRun
SubInputRun.__abstractmethods__
SubInputRun.__getitem__()
SubInputRun.__getstate__()
SubInputRun.__init__()
SubInputRun.__module__
SubInputRun.__setstate__()
SubInputRun.__str__()
SubInputRun.cardinality()
SubInputRun.description
SubInputRun.dimensions
SubInputRun.fullid
SubInputRun.get_sourced_nodes()
SubInputRun.get_sourced_outputs()
SubInputRun.input_group
SubInputRun.item_index
SubInputRun.iteritems()
SubInputRun.itersubinputs()
SubInputRun.node
SubInputRun.source
SubInputRun.source_output
SubOutputRun
SubOutputRun.__abstractmethods__
SubOutputRun.__getitem__()
SubOutputRun.__getstate__()
SubOutputRun.__init__()
SubOutputRun.__len__()
SubOutputRun.__module__
SubOutputRun.__setitem__()
SubOutputRun.__setstate__()
SubOutputRun.__str__()
SubOutputRun.cardinality()
SubOutputRun.datatype
SubOutputRun.fullid
SubOutputRun.indexrep
SubOutputRun.listeners
SubOutputRun.node
SubOutputRun.preferred_types
SubOutputRun.resulting_datatype
SubOutputRun.samples
job
ModuleInlineJob
Job
Job.COMMAND_DUMP
Job.INFO_DUMP
Job.PROV_DUMP
Job.RESULT_DUMP
Job.STDERR_DUMP
Job.STDOUT_DUMP
Job.__getstate__()
Job.__init__()
Job.__module__
Job.__repr__()
Job.__setstate__()
Job.cast_to_type()
Job.clean()
Job.collect_provenance()
Job.commandfile
Job.commandurl
Job.create_payload()
Job.ensure_tmp_dir()
Job.execute()
Job.extrainfofile
Job.extrainfourl
Job.fill_output_argument()
Job.fullid
Job.get_deferred()
Job.get_output_datatype()
Job.get_result()
Job.get_value()
Job.hash_inputs()
Job.hash_results()
Job.id
Job.logfile
Job.logurl
Job.provfile
Job.provurl
Job.resources
Job.status
Job.stderrfile
Job.stderrurl
Job.stdoutfile
Job.stdouturl
Job.tmpdir
Job.tmpurl
Job.tool
Job.translate_argument()
Job.translate_output_results()
Job.translate_results()
Job.validate_results()
Job.write()
JobCleanupLevel
JobState
JobState.__init__()
JobState.__module__
JobState.cancelled
JobState.created
JobState.done
JobState.execution_done
JobState.execution_failed
JobState.execution_skipped
JobState.failed
JobState.finished
JobState.hold
JobState.idle
JobState.in_progress
JobState.nonexistent
JobState.processing_callback
JobState.queued
JobState.running
SinkJob
SourceJob
linkrun
ModuleLinkRun
LinkRun.__abstractmethods__
LinkRun.__dataschemafile__
LinkRun.__eq__()
LinkRun.__getitem__()
LinkRun.__getstate__()
LinkRun.__hash__
LinkRun.__init__()
LinkRun.__module__
LinkRun.__repr__()
LinkRun.__setstate__()
LinkRun.cardinality()
LinkRun.collapse
LinkRun.collapse_indexes
LinkRun.createobj()
LinkRun.destroy()
LinkRun.dimensions
LinkRun.expand
LinkRun.fullid
LinkRun.parent
LinkRun.size
LinkRun.source
LinkRun.status
LinkRun.target
macronoderun
Modulenetworkanalyzer
Modulenetworkchunker
Modulenetworkrun
ModuleNetworkRun
NetworkRun.NETWORK_DUMP_FILE_NAME
NetworkRun.SINK_DUMP_FILE_NAME
NetworkRun.SOURCE_DUMP_FILE_NAME
NetworkRun.__bool__()
NetworkRun.__eq__()
NetworkRun.__getitem__()
NetworkRun.__getstate__()
NetworkRun.__hash__
NetworkRun.__init__()
NetworkRun.__module__
NetworkRun.__ne__()
NetworkRun.__repr__()
NetworkRun.__setstate__()
NetworkRun.abort()
NetworkRun.check_id()
NetworkRun.constantlist
NetworkRun.execute()
NetworkRun.execution_finished()
NetworkRun.fullid
NetworkRun.generate_jobs()
NetworkRun.global_id
NetworkRun.id
NetworkRun.job_finished()
NetworkRun.long_id
NetworkRun.network
NetworkRun.nodegroups
NetworkRun.register_signals()
NetworkRun.set_data()
NetworkRun.sinklist
NetworkRun.sourcelist
NetworkRun.unregister_signals()
noderun
ModuleNodeRun
NodeRun.__abstractmethods__
NodeRun.__dataschemafile__
NodeRun.__eq__()
NodeRun.__getstate__()
NodeRun.__hash__
NodeRun.__init__()
NodeRun.__module__
NodeRun.__repr__()
NodeRun.__setstate__()
NodeRun.__str__()
NodeRun.blocking
NodeRun.create_job()
NodeRun.createobj()
NodeRun.dimnames
NodeRun.execute()
NodeRun.find_source_index()
NodeRun.fullid
NodeRun.get_sourced_nodes()
NodeRun.global_id
NodeRun.id
NodeRun.input_groups
NodeRun.listeners
NodeRun.merge_dimensions
NodeRun.name
NodeRun.outputsize
NodeRun.parent
NodeRun.resources
NodeRun.set_result()
NodeRun.status
NodeRun.tool
NodeRun.update_input_groups()
sinknoderun
Modulesourcenoderun
ModuleConstantNodeRun
SourceNodeRun
SourceNodeRun.__abstractmethods__
SourceNodeRun.__dataschemafile__
SourceNodeRun.__eq__()
SourceNodeRun.__getstate__()
SourceNodeRun.__hash__
SourceNodeRun.__init__()
SourceNodeRun.__module__
SourceNodeRun.__setstate__()
SourceNodeRun.create_job()
SourceNodeRun.datatype
SourceNodeRun.dimnames
SourceNodeRun.output
SourceNodeRun.outputsize
SourceNodeRun.set_data()
SourceNodeRun.sourcegroup
SourceNodeRun.valid
- helpers Package
helpers
Packagechecksum
Moduleclassproperty
Moduleclear_pycs
Moduleconfigmanager
ModuleConfig
Config.DEFAULT_FIELDS
Config.__dict__
Config.__init__()
Config.__module__
Config.__repr__()
Config.__weakref__
Config.debug
Config.examplesdir
Config.execution_plugin
Config.executionscript
Config.extra_config_dirs
Config.filesynchelper_url
Config.get_field()
Config.job_cleanup_level
Config.log_to_file
Config.logdir
Config.logging_config
Config.loglevel
Config.logtype
Config.mounts
Config.networks_path
Config.pim_batch_size
Config.pim_debug
Config.pim_finished_timeout
Config.pim_host
Config.pim_update_interval
Config.pim_username
Config.plugins_path
Config.preferred_types
Config.process_pool_worker_number
Config.protected_modules
Config.queue_report_interval
Config.read_config()
Config.read_config_files
Config.read_config_string()
Config.register_fields()
Config.reporting_plugins
Config.resourcesdir
Config.schemadir
Config.set_field()
Config.slurm_job_check_interval
Config.slurm_partition
Config.source_job_limit
Config.systemdir
Config.tools_path
Config.types_path
Config.userdir
Config.warn_develop
Config.web_hostname
Config.web_url()
EmptyDefault
EmptyDefault.__add__()
EmptyDefault.__delitem__()
EmptyDefault.__dict__
EmptyDefault.__getitem__()
EmptyDefault.__iadd__()
EmptyDefault.__init__()
EmptyDefault.__module__
EmptyDefault.__radd__()
EmptyDefault.__setitem__()
EmptyDefault.__weakref__
EmptyDefault.append()
EmptyDefault.asdict()
EmptyDefault.aslist()
EmptyDefault.extend()
EmptyDefault.merge_default()
EmptyDefault.prepend()
EmptyDefault.update()
FastrLogRecordFilter
events
Modulefilesynchelper
ModuleFileSyncHelper
FileSyncHelper.__dict__
FileSyncHelper.__init__()
FileSyncHelper.__module__
FileSyncHelper.__weakref__
FileSyncHelper.has_file_promise()
FileSyncHelper.job_finished()
FileSyncHelper.load()
FileSyncHelper.make_file_promise()
FileSyncHelper.store()
FileSyncHelper.wait_for_file()
FileSyncHelper.wait_for_job()
FileSyncHelper.wait_for_pickle()
FileSyncHelper.wait_for_vfs_url()
filesynchelper_enabled()
iohelpers
Modulejsonschemaparser
Modulelazy_module
Modulelockfile
ModuleDirectoryLock
DirectoryLock.__annotations__
DirectoryLock.__del__()
DirectoryLock.__dict__
DirectoryLock.__enter__()
DirectoryLock.__exit__()
DirectoryLock.__init__()
DirectoryLock.__module__
DirectoryLock.__weakref__
DirectoryLock.acquire()
DirectoryLock.get_pid()
DirectoryLock.lock_dir
DirectoryLock.lock_dir_name
DirectoryLock.pid_file
DirectoryLock.pid_file_name
DirectoryLock.release()
procutils
Modulereport
Modulerest_generation
Moduleschematotable
Moduleshellescape
Modulesysinfo
Modulexmltodict
Module
- planning Package
planning
Packageinputgroup
ModuleInputGroup
InputGroup.__abstractmethods__
InputGroup.__getitem__()
InputGroup.__init__()
InputGroup.__module__
InputGroup.__setitem__()
InputGroup.__updatefunc__()
InputGroup.__updatetriggers__
InputGroup.dimensions
InputGroup.empty
InputGroup.find_source_index()
InputGroup.fullid
InputGroup.iterinputvalues
InputGroup.parent
InputGroup.primary
InputGroup.solve_broadcast()
inputgroupcombiner
ModuleBaseInputGroupCombiner
BaseInputGroupCombiner.__abstractmethods__
BaseInputGroupCombiner.__init__()
BaseInputGroupCombiner.__iter__()
BaseInputGroupCombiner.__module__
BaseInputGroupCombiner.dimensions
BaseInputGroupCombiner.fullid
BaseInputGroupCombiner.input_groups
BaseInputGroupCombiner.iter_input_groups()
BaseInputGroupCombiner.merge()
BaseInputGroupCombiner.merge_failed_annotations()
BaseInputGroupCombiner.merge_payloads()
BaseInputGroupCombiner.merge_sample_data()
BaseInputGroupCombiner.merge_sample_id()
BaseInputGroupCombiner.merge_sample_index()
BaseInputGroupCombiner.merge_sample_jobs()
BaseInputGroupCombiner.merge_sample_status()
BaseInputGroupCombiner.unmerge()
BaseInputGroupCombiner.update()
DefaultInputGroupCombiner
MergingInputGroupCombiner
inputoutput
ModuleAdvancedFlowOutput
BaseInput
BaseInputOutput
BaseInputOutput.__abstractmethods__
BaseInputOutput.__getstate__()
BaseInputOutput.__init__()
BaseInputOutput.__iter__()
BaseInputOutput.__module__
BaseInputOutput.__ne__()
BaseInputOutput.__repr__()
BaseInputOutput.__setstate__()
BaseInputOutput.cardinality()
BaseInputOutput.check_cardinality()
BaseInputOutput.datatype
BaseInputOutput.description
BaseInputOutput.description_type
BaseInputOutput.fullid
BaseInputOutput.id
BaseInputOutput.node
BaseInputOutput.required
BaseOutput
Input
Input.__abstractmethods__
Input.__eq__()
Input.__getitem__()
Input.__getstate__()
Input.__hash__
Input.__init__()
Input.__module__
Input.__setitem__()
Input.__setstate__()
Input.__str__()
Input.append()
Input.cardinality()
Input.clear()
Input.constant_id
Input.datatype
Input.dimensions
Input.fullid
Input.get_sourced_nodes()
Input.get_sourced_outputs()
Input.id
Input.index()
Input.input_group
Input.insert()
Input.itersubinputs()
Input.remove()
Input.source
MacroInput
MacroOutput
NamedSubInput
Output
Output.__abstractmethods__
Output.__eq__()
Output.__getitem__()
Output.__getstate__()
Output.__hash__
Output.__init__()
Output.__module__
Output.__setstate__()
Output.__str__()
Output.cardinality()
Output.datatype
Output.dimensions
Output.fullid
Output.listeners
Output.preferred_types
Output.resulting_datatype
Output.valid
SourceOutput
SubInput
SubInput.__abstractmethods__
SubInput.__eq__()
SubInput.__getitem__()
SubInput.__getstate__()
SubInput.__hash__
SubInput.__init__()
SubInput.__module__
SubInput.__setstate__()
SubInput.__str__()
SubInput.cardinality()
SubInput.constant_id
SubInput.description
SubInput.dimensions
SubInput.fullid
SubInput.get_sourced_nodes()
SubInput.get_sourced_outputs()
SubInput.input_group
SubInput.item_index
SubInput.iteritems()
SubInput.itersubinputs()
SubInput.node
SubInput.remove()
SubInput.source
SubInput.source_output
SubOutput
SubOutput.__abstractmethods__
SubOutput.__eq__()
SubOutput.__getstate__()
SubOutput.__hash__
SubOutput.__init__()
SubOutput.__len__()
SubOutput.__module__
SubOutput.__setstate__()
SubOutput.__str__()
SubOutput.cardinality()
SubOutput.datatype
SubOutput.fullid
SubOutput.indexrep
SubOutput.listeners
SubOutput.node
SubOutput.preferred_types
SubOutput.resulting_datatype
SubOutput.samples
link
ModuleLink
Link.__abstractmethods__
Link.__dataschemafile__
Link.__eq__()
Link.__getstate__()
Link.__hash__
Link.__init__()
Link.__module__
Link.__repr__()
Link.__setstate__()
Link.cardinality()
Link.collapse
Link.collapse_indexes
Link.createobj()
Link.destroy()
Link.dimensions
Link.draw()
Link.expand
Link.fullid
Link.parent
Link.source
Link.status
Link.target
network
ModuleNetwork
Network.NETWORK_DUMP_FILE_NAME
Network.SINK_DUMP_FILE_NAME
Network.SOURCE_DUMP_FILE_NAME
Network.__dataschemafile__
Network.__eq__()
Network.__getitem__()
Network.__getstate__()
Network.__hash__
Network.__init__()
Network.__module__
Network.__ne__()
Network.__repr__()
Network.__setstate__()
Network.add_link()
Network.add_node()
Network.add_stepid()
Network.check_id()
Network.create_constant()
Network.create_link()
Network.create_macro()
Network.create_node()
Network.create_reference()
Network.create_sink()
Network.create_source()
Network.dependencies()
Network.draw()
Network.draw_network()
Network.execute()
Network.fullid
Network.global_id
Network.id
Network.is_valid()
Network.namespace
Network.nodegroups
Network.ns_id
Network.remove()
Network.test()
node
ModuleAdvancedFlowNode
BaseNode
ConstantNode
FlowNode
InputDict
MacroNode
Node
Node.__abstractmethods__
Node.__dataschemafile__
Node.__eq__()
Node.__getstate__()
Node.__hash__
Node.__init__()
Node.__module__
Node.__ne__()
Node.__repr__()
Node.__setstate__()
Node.__str__()
Node.blocking
Node.createobj()
Node.dimensions
Node.dimnames
Node.draw()
Node.draw_id()
Node.draw_link_target()
Node.find_source_index()
Node.fullid
Node.get_sourced_nodes()
Node.global_id
Node.id
Node.input_groups
Node.inputs
Node.listeners
Node.merge_dimensions
Node.name
Node.nodegroup
Node.outputs
Node.outputsize
Node.parent
Node.status
Node.tool
Node.update_input_groups()
OutputDict
SinkNode
SourceNode
SourceNode.__abstractmethods__
SourceNode.__dataschemafile__
SourceNode.__getstate__()
SourceNode.__init__()
SourceNode.__module__
SourceNode.__setstate__()
SourceNode.datatype
SourceNode.dimensions
SourceNode.draw()
SourceNode.nodegroup
SourceNode.output
SourceNode.set_data()
SourceNode.sourcegroup
SourceNode.valid
- Subpackages
- plugins Package
plugins
PackageBlockingExecution
CommaSeperatedValueFile
CrossValidation
DRMAAExecution
DRMAAExecution.CANCELS_DEPENDENCIES
DRMAAExecution.GE_NATIVE_SPEC
DRMAAExecution.NATIVE_SPEC
DRMAAExecution.SUPPORTS_CANCEL
DRMAAExecution.SUPPORTS_DEPENDENCY
DRMAAExecution.SUPPORTS_HOLD_RELEASE
DRMAAExecution.TORQUE_NATIVE_SPEC
DRMAAExecution.__abstractmethods__
DRMAAExecution.__init__()
DRMAAExecution.__module__
DRMAAExecution.check_threads()
DRMAAExecution.cleanup()
DRMAAExecution.collect_jobs()
DRMAAExecution.configuration_fields
DRMAAExecution.create_native_spec()
DRMAAExecution.dispatch_callbacks()
DRMAAExecution.ensure_threads()
DRMAAExecution.filename
DRMAAExecution.module
DRMAAExecution.n_current_jobs
DRMAAExecution.regression_check()
DRMAAExecution.send_job()
DRMAAExecution.spec_fields
DRMAAExecution.submit_jobs()
DRMAAExecution.test()
DockerTarget
ElasticsearchReporter
ElasticsearchReporter.__abstractmethods__
ElasticsearchReporter.__init__()
ElasticsearchReporter.__module__
ElasticsearchReporter.activate()
ElasticsearchReporter.configuration_fields
ElasticsearchReporter.elasticsearch_update_status()
ElasticsearchReporter.filename
ElasticsearchReporter.job_updated()
ElasticsearchReporter.module
ElasticsearchReporter.test()
FastrInterface
FastrInterface.__abstractmethods__
FastrInterface.__dataschemafile__
FastrInterface.__eq__()
FastrInterface.__getstate__()
FastrInterface.__hash__
FastrInterface.__init__()
FastrInterface.__module__
FastrInterface.__setstate__()
FastrInterface.check_input_id()
FastrInterface.check_output_id()
FastrInterface.collect_errors()
FastrInterface.collect_results()
FastrInterface.collector_plugin_type
FastrInterface.collectors
FastrInterface.execute()
FastrInterface.expanding
FastrInterface.filename
FastrInterface.get_arguments()
FastrInterface.get_command()
FastrInterface.get_specials()
FastrInterface.inputs
FastrInterface.module
FastrInterface.outputs
FileSystem
FlowInterface
FlowInterface.__abstractmethods__
FlowInterface.__dataschemafile__
FlowInterface.__eq__()
FlowInterface.__getstate__()
FlowInterface.__hash__
FlowInterface.__init__()
FlowInterface.__module__
FlowInterface.__setstate__()
FlowInterface.execute()
FlowInterface.expanding
FlowInterface.filename
FlowInterface.flow_plugin_type
FlowInterface.flow_plugins
FlowInterface.inputs
FlowInterface.module
FlowInterface.outputs
HTTPPlugin
LinearExecution
LocalBinaryTarget
LocalBinaryTarget.DYNAMIC_LIBRARY_PATH_DICT
LocalBinaryTarget.__abstractmethods__
LocalBinaryTarget.__enter__()
LocalBinaryTarget.__exit__()
LocalBinaryTarget.__init__()
LocalBinaryTarget.__module__
LocalBinaryTarget.filename
LocalBinaryTarget.module
LocalBinaryTarget.paths
LocalBinaryTarget.run_command()
MacroTarget
NetworkScope
NipypeInterface
NipypeInterface.__abstractmethods__
NipypeInterface.__eq__()
NipypeInterface.__getstate__()
NipypeInterface.__hash__
NipypeInterface.__init__()
NipypeInterface.__module__
NipypeInterface.__setstate__()
NipypeInterface.execute()
NipypeInterface.expanding
NipypeInterface.filename
NipypeInterface.get_type()
NipypeInterface.inputs
NipypeInterface.module
NipypeInterface.outputs
NipypeInterface.test()
Null
PimReporter
PimReporter.SUPPORTED_APIS
PimReporter.__abstractmethods__
PimReporter.__init__()
PimReporter.__module__
PimReporter.activate()
PimReporter.configuration_fields
PimReporter.filename
PimReporter.job_updated()
PimReporter.log_record_emitted()
PimReporter.module
PimReporter.run_finished()
PimReporter.run_started()
ProcessPoolExecution
ProcessPoolExecution.__abstractmethods__
ProcessPoolExecution.__init__()
ProcessPoolExecution.__module__
ProcessPoolExecution.cleanup()
ProcessPoolExecution.configuration_fields
ProcessPoolExecution.filename
ProcessPoolExecution.job_finished_callback()
ProcessPoolExecution.module
ProcessPoolExecution.test()
RQExecution
Reference
S3Filesystem
S3Filesystem.__abstractmethods__
S3Filesystem.__init__()
S3Filesystem.__module__
S3Filesystem.cleanup()
S3Filesystem.expand_url()
S3Filesystem.fetch_url()
S3Filesystem.fetch_value()
S3Filesystem.filename
S3Filesystem.module
S3Filesystem.put_url()
S3Filesystem.put_value()
S3Filesystem.scheme
S3Filesystem.test()
SimpleReport
SingularityTarget
SlurmExecution
SlurmExecution.SBATCH
SlurmExecution.SCANCEL
SlurmExecution.SCONTROL
SlurmExecution.SQUEUE
SlurmExecution.SQUEUE_FORMAT
SlurmExecution.STATUS_MAPPING
SlurmExecution.SUPPORTS_CANCEL
SlurmExecution.SUPPORTS_DEPENDENCY
SlurmExecution.SUPPORTS_HOLD_RELEASE
SlurmExecution.__abstractmethods__
SlurmExecution.__init__()
SlurmExecution.__module__
SlurmExecution.cleanup()
SlurmExecution.configuration_fields
SlurmExecution.filename
SlurmExecution.job_status_check()
SlurmExecution.module
SlurmExecution.test()
StrongrExecution
VirtualFileSystem
VirtualFileSystemRegularExpression
VirtualFileSystemRegularExpression.__abstractmethods__
VirtualFileSystemRegularExpression.__init__()
VirtualFileSystemRegularExpression.__module__
VirtualFileSystemRegularExpression.expand_url()
VirtualFileSystemRegularExpression.filename
VirtualFileSystemRegularExpression.module
VirtualFileSystemRegularExpression.scheme
VirtualFileSystemValueList
XNATStorage
XNATStorage.__abstractmethods__
XNATStorage.__init__()
XNATStorage.__module__
XNATStorage.cleanup()
XNATStorage.connect()
XNATStorage.expand_url()
XNATStorage.fetch_url()
XNATStorage.filename
XNATStorage.module
XNATStorage.parse_uri()
XNATStorage.put_url()
XNATStorage.scheme
XNATStorage.server
XNATStorage.upload()
XNATStorage.xnat
json
path
stdout
executionplugin
ModuleExecutionPlugin
ExecutionPlugin.CANCELS_DEPENDENCIES
ExecutionPlugin.SUPPORTS_CANCEL
ExecutionPlugin.SUPPORTS_DEPENDENCY
ExecutionPlugin.SUPPORTS_HOLD_RELEASE
ExecutionPlugin.__abstractmethods__
ExecutionPlugin.__del__()
ExecutionPlugin.__enter__()
ExecutionPlugin.__exit__()
ExecutionPlugin.__init__()
ExecutionPlugin.__module__
ExecutionPlugin.cancel_job()
ExecutionPlugin.check_job_requirements()
ExecutionPlugin.check_job_status()
ExecutionPlugin.check_nr_queued_jobs()
ExecutionPlugin.clean_free_jobs()
ExecutionPlugin.cleanup()
ExecutionPlugin.get_job()
ExecutionPlugin.get_status()
ExecutionPlugin.hold_job()
ExecutionPlugin.job_finished()
ExecutionPlugin.process_callbacks()
ExecutionPlugin.queue_job()
ExecutionPlugin.register_job()
ExecutionPlugin.release_job()
ExecutionPlugin.show_jobs()
ExecutionPlugin.signal_dependent_jobs()
JobAction
reportingplugin
Module- Subpackages
- managers Package
managers
Packageexecutionpluginmanager
ModuleExecutionPluginManager
ExecutionPluginManager.__abstractmethods__
ExecutionPluginManager.__args__
ExecutionPluginManager.__extra__
ExecutionPluginManager.__init__()
ExecutionPluginManager.__module__
ExecutionPluginManager.__next_in_mro__
ExecutionPluginManager.__orig_bases__
ExecutionPluginManager.__origin__
ExecutionPluginManager.__parameters__
ExecutionPluginManager.__subclasshook__()
ExecutionPluginManager.__tree_hash__
interfacemanager
ModuleInterfacePluginManager
InterfacePluginManager.__abstractmethods__
InterfacePluginManager.__args__
InterfacePluginManager.__extra__
InterfacePluginManager.__init__()
InterfacePluginManager.__module__
InterfacePluginManager.__next_in_mro__
InterfacePluginManager.__orig_bases__
InterfacePluginManager.__origin__
InterfacePluginManager.__parameters__
InterfacePluginManager.__subclasshook__()
InterfacePluginManager.__tree_hash__
iopluginmanager
ModuleIOPluginManager
IOPluginManager.__abstractmethods__
IOPluginManager.__args__
IOPluginManager.__extra__
IOPluginManager.__init__()
IOPluginManager.__iter__()
IOPluginManager.__keytransform__()
IOPluginManager.__module__
IOPluginManager.__next_in_mro__
IOPluginManager.__orig_bases__
IOPluginManager.__origin__
IOPluginManager.__parameters__
IOPluginManager.__subclasshook__()
IOPluginManager.__tree_hash__
IOPluginManager.cleanup()
IOPluginManager.create_ioplugin_tool()
IOPluginManager.expand_url()
IOPluginManager.pull_source_data()
IOPluginManager.push_sink_data()
IOPluginManager.put_url()
IOPluginManager.register_url_scheme()
IOPluginManager.url_to_path()
networkmanager
ModuleNetworkManager
NetworkManager.__abstractmethods__
NetworkManager.__args__
NetworkManager.__extra__
NetworkManager.__module__
NetworkManager.__next_in_mro__
NetworkManager.__orig_bases__
NetworkManager.__origin__
NetworkManager.__parameters__
NetworkManager.__subclasshook__()
NetworkManager.__tree_hash__
NetworkManager.get_object_version()
NetworkManager.object_class
objectmanager
ModuleObjectManager
ObjectManager.__abstractmethods__
ObjectManager.__args__
ObjectManager.__contains__()
ObjectManager.__extra__
ObjectManager.__getitem__()
ObjectManager.__init__()
ObjectManager.__keytransform__()
ObjectManager.__module__
ObjectManager.__next_in_mro__
ObjectManager.__orig_bases__
ObjectManager.__origin__
ObjectManager.__parameters__
ObjectManager.__subclasshook__()
ObjectManager.__tree_hash__
ObjectManager.get_object_version()
ObjectManager.object_class
ObjectManager.objectversions()
ObjectManager.todict()
pluginmanager
ModulePluginManager
PluginManager.__abstractmethods__
PluginManager.__args__
PluginManager.__extra__
PluginManager.__init__()
PluginManager.__module__
PluginManager.__next_in_mro__
PluginManager.__orig_bases__
PluginManager.__origin__
PluginManager.__parameters__
PluginManager.__setitem__()
PluginManager.__subclasshook__()
PluginManager.__tree_hash__
PluginManager.plugin_class
PluginSubManager
PluginSubManager.__abstractmethods__
PluginSubManager.__args__
PluginSubManager.__extra__
PluginSubManager.__init__()
PluginSubManager.__module__
PluginSubManager.__next_in_mro__
PluginSubManager.__orig_bases__
PluginSubManager.__origin__
PluginSubManager.__parameters__
PluginSubManager.__subclasshook__()
PluginSubManager.__tree_hash__
PluginSubManager.data
PluginSubManager.plugin_class
PluginsView
targetmanager
ModuleTargetManager
TargetManager.__abstractmethods__
TargetManager.__args__
TargetManager.__extra__
TargetManager.__init__()
TargetManager.__module__
TargetManager.__next_in_mro__
TargetManager.__orig_bases__
TargetManager.__origin__
TargetManager.__parameters__
TargetManager.__subclasshook__()
TargetManager.__tree_hash__
toolmanager
ModuleToolManager
ToolManager.__abstractmethods__
ToolManager.__args__
ToolManager.__extra__
ToolManager.__module__
ToolManager.__next_in_mro__
ToolManager.__orig_bases__
ToolManager.__origin__
ToolManager.__parameters__
ToolManager.__subclasshook__()
ToolManager.__tree_hash__
ToolManager.get_object_version()
ToolManager.object_class
ToolManager.populate()
ToolManager.toolversions()
- managers Package
- test Package
- utils Package
utils
Packagecompare
Moduledicteq
Modulegettools
Modulemultiprocesswrapper
Moduleverify
Module- Subpackages
- cmd Package
cmd
Packagecat
Moduledump
Moduleexecute
Moduleextract_argparse
Moduleprovenance
Modulepylint
Modulereport
Modulerun
Modulesink
Modulesource
Moduletest
Moduletrace
Moduleupgrade
Moduleverify
Module
- secrets Package
- cmd Package