test_workers.py 文件源码

def test_run_classifying_workers(self, mock_event, mock_pd,
                                     mock_classify, mock_pre_process,
                                     mock_coOc, mock_config,
                                     mock_process):
        queue = Mock()
        w = Workers()

        mock_pre_process.return_value = Mock()

        # Bugs other fixtures if imported globally.
        from testfixtures import LogCapture
        with LogCapture() as l:
            w.run_classifying_workers(1, queue, 1, pre_downloaded=True)
            assert (l.__sizeof__()) > 0
            assert mock_pre_process.called