kedro.runner.parallel_runner._SharedMemoryDataSet

class documentation

class _SharedMemoryDataSet: (source)

_SharedMemoryDataSet is a wrapper class for a shared MemoryDataSet in SyncManager. It is not inherited from AbstractDataSet class.

Method	`__getattr__`	Undocumented
Method	`__init__`	Creates a new instance of `_SharedMemoryDataSet`, and creates shared memorydataset attribute.
Method	`save`	Calls save method of a shared MemoryDataSet in SyncManager.
Instance Variable	`shared_memory_dataset`	Undocumented

def __getattr__(self, name): (source) ¶

Undocumented

def __init__(self, manager: SyncManager): (source) ¶

Creates a new instance of _SharedMemoryDataSet, and creates shared memorydataset attribute.

Parameters
manager:`SyncManager`	An instance of multiprocessing manager for shared objects.

def save(self, data: Any): (source) ¶

Calls save method of a shared MemoryDataSet in SyncManager.

Undocumented