

def create_endpoint(self, *args, **kwargs):
    newkwargs = kwargs.copy()
    newkwargs['process'] = self._process
    return Publisher.create_endpoint(self, *args, **newkwargs)

dataset/ETHPy150Open ooici/pyon/pyon/ion/endpoint.py ProcessPublisher.create_endpoint/original