(self, get_df, queue)
| 407 | |
| 408 | class _Worker(StoppableThread): |
| 409 | def __init__(self, get_df, queue): |
| 410 | super(MultiThreadRunner._Worker, self).__init__() |
| 411 | self.df = get_df() |
| 412 | assert isinstance(self.df, DataFlow), self.df |
| 413 | self.queue = queue |
| 414 | self.daemon = True |
| 415 | |
| 416 | def run(self): |
| 417 | self.df.reset_state() |