Add new items to the work queue. The specifics will vary depending on whether this is a local or S3-backed queue. Args: work_paths: Each individual path that we will process over items_per_group: Number of items to group together in a single work ite
(self, work_paths: List[str], items_per_group: int)
| 27 | |
| 28 | @abc.abstractmethod |
| 29 | async def populate_queue(self, work_paths: List[str], items_per_group: int) -> None: |
| 30 | """ |
| 31 | Add new items to the work queue. The specifics will vary depending on |
| 32 | whether this is a local or S3-backed queue. |
| 33 | |
| 34 | Args: |
| 35 | work_paths: Each individual path that we will process over |
| 36 | items_per_group: Number of items to group together in a single work item |
| 37 | """ |
| 38 | pass |
| 39 | |
| 40 | @abc.abstractmethod |
| 41 | async def initialize_queue(self) -> int: |
nothing calls this directly
no outgoing calls
no test coverage detected