Load the work queue from the relevant store (local or remote) and initialize it for processing. For example, this might remove already completed work items and randomize the order before adding them to an internal queue.
(self)
| 39 | |
| 40 | @abc.abstractmethod |
| 41 | async def initialize_queue(self) -> int: |
| 42 | """ |
| 43 | Load the work queue from the relevant store (local or remote) |
| 44 | and initialize it for processing. |
| 45 | |
| 46 | For example, this might remove already completed work items and randomize |
| 47 | the order before adding them to an internal queue. |
| 48 | """ |
| 49 | pass |
| 50 | |
| 51 | @abc.abstractmethod |
| 52 | async def is_completed(self, work_hash: str) -> bool: |
nothing calls this directly
no outgoing calls
no test coverage detected