(self, binding)
| 279 | return self.queue and (not self.store.is_terminated()) |
| 280 | |
| 281 | def push_binding(self, binding): |
| 282 | # TODO: add to standby if not active |
| 283 | priority = binding.get_priority() |
| 284 | element = HeapElement(priority, binding) |
| 285 | heappush(self.queue, element) |
| 286 | |
| 287 | def pop_binding(self): |
| 288 | priority, binding = heappop(self.queue) |
no test coverage detected