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