alphatwirl.concurrently.WorkingArea¶
-
class
alphatwirl.concurrently.WorkingArea(**kwargs)[source]¶ A working area for tasks
This is an area where pickled tasks, pickled results, archived Python modules, etc are placed.
Parameters: - topdir (str) – a path to a directory in which a new directory will be created
- python_modules (list) – names of Python modules to be shipped to worker nodes
-
__init__(**kwargs)¶
Methods
__init__(**kwargs)close()Close the working area collect_result(package_index)Collect the result of a task open()Open the working area package_fullpath(package_index)Returns the full path of the package package_path(package_index)package_relpath(package_index)Returns the relative path of the package put_package(package)Put a package result_fullpath(package_index)Returns the full path of the result result_relpath(package_index)Returns the relative path of the result