Check if a work item has been completed. Args: work_hash: Hash of the work item to check Returns: True if the work is completed, False otherwise
(self, work_hash: str)
| 50 | |
| 51 | @abc.abstractmethod |
| 52 | async def is_completed(self, work_hash: str) -> bool: |
| 53 | """ |
| 54 | Check if a work item has been completed. |
| 55 | |
| 56 | Args: |
| 57 | work_hash: Hash of the work item to check |
| 58 | |
| 59 | Returns: |
| 60 | True if the work is completed, False otherwise |
| 61 | """ |
| 62 | pass |
| 63 | |
| 64 | @abc.abstractmethod |
| 65 | async def get_work(self, worker_lock_timeout_secs: int = 1800) -> Optional[WorkItem]: |
nothing calls this directly
no outgoing calls
no test coverage detected