

def setUp(self, **kwargs):
    self.return_message = None
    self.return_stream = None
    self.sink_properties = None
    self.global_properties = {
        SinkProperties.Label: 'mock',
    }
    kwargs.customize(**kwargs)
    self.mock_provider = MockSinkProvider()
    self.sink = self._createSink()
    self.sink.Open().wait()
    self._prepareSinkStack()
    self._waitForSink()

dataset/ETHPy150Open steveniemitz/scales/test/scales/util/base.py SinkTestCase.setUp/VarMisuse@46/55 `self`->`kwargs`