

def __init__(self, properties):
    super(MockSink, self).__init__()
    self._state = ChannelState.Idle
    self.ProcessRequest = None
    self.ProcessResponse = None
    self._open_delay = properties.get('open_delay', 0)
    self._num_failures = properties.get('num_failures', [0])
    self._properties = properties
    self._open_result = None
    self.endpoint = properties[SinkProperties.Endpoint]

dataset/ETHPy150Open steveniemitz/scales/test/scales/util/mocks.py MockSink.__init__/original