(self, *args, **kwargs)
| 76 | return new_items[0] if single_item and new_items else new_items |
| 77 | |
| 78 | def put(self, *args, **kwargs): |
| 79 | if self._finished: |
| 80 | raise RuntimeError("Cannot put items after get() was called") |
| 81 | |
| 82 | if args: |
| 83 | unique_args = self.get_unique(args[0]) |
| 84 | args_to_put = (unique_args, *args[1:]) |
| 85 | else: |
| 86 | args_to_put = () |
| 87 | |
| 88 | self._task_queue.put([args_to_put, kwargs]) |
| 89 | |
| 90 | def get(self): |
| 91 | import sys |
no test coverage detected