@retry(9, Exception, 0.01, 'pypet.retry')
    def _put_on_pipe(self, to_put):
        self.acquire_lock()
        self._send_chunks(to_put)
        self.release_lock()
Load all plugins from dgit extension
dataset/ETHPy150Open SmokinCaterpillar/pypet/pypet/utils/mpwrappers.py/PipeStorageServiceSender._put_on_pipe--crossover with--dataset/ETHPy150Open pingali/dgit/dgitcore/plugins/common.py/PluginManager.discover_all_plugins