kedro/runner/parallel_runner.py
def save(self, data: Any):
        """Calls save method of a shared MemoryDataSet in SyncManager.
        """
        try:
            self.shared_memory_dataset.save(data)
        except Exception as exc:  # pylint: disable=broad-except
            # Checks if the error is due to serialisation or not
            try:
                pickle.dumps(data)
            except Exception:  # SKIP_IF_NO_SPARK
                raise DataSetError(
                    "{} cannot be serialized. ParallelRunner implicit memory datasets "
                    "can only be used with serializable data".format(
                        str(data.__class__)
                    )
                )
            else:
                raise exc
Calls save method of a shared MemoryDataSet in SyncManager.
        
Calls save method of a shared MemoryDataSet in SyncManager.
Calls save method of a shared MemoryDataSet in SyncManager .
def save(self, data: Any):
        try:
            self.shared_memory_dataset.save(data)
        except Exception as exc:  
            try:
                pickle.dumps(data)
            except Exception:  
                raise DataSetError(
                    "{} cannot be serialized. ParallelRunner implicit memory datasets "
                    "can only be used with serializable data".format(
                        str(data.__class__)
                    )
                )
            else:
                raise exc
def save ( self , data : Any ) : try : self . shared_memory_dataset . save ( data ) except Exception as exc : try : pickle . dumps ( data ) except Exception : raise DataSetError ( "{} cannot be serialized. ParallelRunner implicit memory datasets " "can only be used with serializable data" . format ( str ( data . __class__ ) ) ) else : raise exc
Calls save method of a shared MemoryDataSet in SyncManager.
Calls save method of a shared MemoryDataSet in SyncManager .
"""Calls save method of a shared MemoryDataSet in SyncManager.
        """ # pylint: disable=broad-except # Checks if the error is due to serialisation or not # SKIP_IF_NO_SPARK
self
data
Any