Check if the queue is currently processing tasks
(self)
| 189 | self._cleanup_performed = False |
| 190 | |
| 191 | def is_processing(self) -> bool: |
| 192 | """Check if the queue is currently processing tasks""" |
| 193 | return self._worker_task is not None and self._worker_task.is_alive() |
| 194 | |
| 195 | def start_worker(self) -> bool: |
| 196 | """Start the task worker if not already running. Returns True if started, False if already running.""" |