def test_selfsubworkflows_threads(self):
        try:
            from futures import ThreadPoolExecutor
        except __HOLE__:
            from concurrent.futures import ThreadPoolExecutor
        sub = LocalWorkflow(W, executor=ThreadPoolExecutor)
        sub.conf_activity('m', tactivity)
        sub.conf_activity('r', tactivity)
        main = LocalWorkflow(W, executor=ThreadPoolExecutor)
        main.conf_workflow('m', sub)
        main.conf_activity('r', tactivity)
        result = main.run(8, r=True, _wait=True)
        self.assertEquals(result, 165)
dataset/ETHPy150Open severb/flowy/tests/test_local.py/TestLocalWorkflow.test_selfsubworkflows_threads