(future)
| 1659 | self._poll_queue.task_done() |
| 1660 | |
| 1661 | def add(future): |
| 1662 | # add future to query frame_futures |
| 1663 | # returns: worker lives on? |
| 1664 | |
| 1665 | # `None` task signifies thread termination |
| 1666 | if future is None: |
| 1667 | task_done() |
| 1668 | return False |
| 1669 | |
| 1670 | if future.id not in frame_futures and not future.done(): |
| 1671 | frame_futures[future.id] = future |
| 1672 | else: |
| 1673 | task_done() |
| 1674 | |
| 1675 | return True |
| 1676 | |
| 1677 | while True: |
| 1678 | frame_futures.clear() |
no test coverage detected