aiida.work.legacy package

Submodules

class aiida.work.legacy.job_process.JobProcess

Bases: aiida.work.process.Process

CALC_NODE_LABEL = 'calc_node'

OPTIONS_INPUT_LABEL = '_options'

_CALC_CLASS = None

__abstractmethods__ = frozenset([])

__module__ = 'aiida.work.legacy.job_process'

_abc_cache = <_weakrefset.WeakSet object>

_abc_negative_cache = <_weakrefset.WeakSet object>

_abc_negative_cache_version = 95

_abc_registry = <_weakrefset.WeakSet object>

_on_output_emitted(output_port, value, dynamic)

The process has emitted a value on the given output port.

Parameters:

• output_port – The output port name the value was emitted on
• value – The value emitted
• dynamic – Was the output port a dynamic one (i.e. not known beforehand?)

_run(**kwargs)

_setup_db_record()

Link up all the retrospective provenance for this JobCalculation

classmethod build(calc_class)

calculation_finished(wait_on)

The callback function that is called when the remote calculation is finished.

Parameters:wait_on (aiida.work.legacy.wait_on.WaitOnJobCalculation) – The original WaitOnJobCalculation object.

create_db_record()

Create a database calculation node that represents what happened in this process. :return:

class aiida.work.legacy.wait_on.WaitOnJobCalculation(callback_name, pk)

Bases: plum.wait.WaitOn

PK = 'pk'

__abstractmethods__ = frozenset([])

__init__(callback_name, pk)

x.__init__(…) initializes x; see help(type(x)) for signature

__module__ = 'aiida.work.legacy.wait_on'

_abc_cache = <_weakrefset.WeakSet object>

_abc_negative_cache = <_weakrefset.WeakSet object>

_abc_negative_cache_version = 95

_abc_registry = <_weakrefset.WeakSet object>

classmethod create_from(bundle)

is_ready(registry=None)

save_instance_state(out_state)

class aiida.work.legacy.wait_on.WaitOnWorkflow(callback, pk)

Bases: plum.wait.WaitOn

PK = 'pk'

__abstractmethods__ = frozenset([])

__init__(callback, pk)

x.__init__(…) initializes x; see help(type(x)) for signature

__module__ = 'aiida.work.legacy.wait_on'

_abc_cache = <_weakrefset.WeakSet object>

_abc_negative_cache = <_weakrefset.WeakSet object>

_abc_negative_cache_version = 95

_abc_registry = <_weakrefset.WeakSet object>

is_ready()

save_instance_state(out_state)

aiida.work.legacy.wait_on.wait_on_job_calculation(callback, pk)

aiida.work.legacy.wait_on.wait_on_workflow(callback, pk)