Function
process_events_queue
(queue_ref: weakref.ReferenceType[queue.Queue])
Source from the content-addressed store, hash-verified
| 85 | |
| 86 | |
| 87 | def process_events_queue(queue_ref: weakref.ReferenceType[queue.Queue]) -> bool: # type: ignore[type-arg] |
| 88 | q = queue_ref() |
| 89 | if not q: |
| 90 | return False # Cancel PeriodicExecutor. |
| 91 | |
| 92 | while True: |
| 93 | try: |
| 94 | event = q.get_nowait() |
| 95 | except queue.Empty: |
| 96 | break |
| 97 | else: |
| 98 | fn, args = event |
| 99 | fn(*args) |
| 100 | |
| 101 | return True # Continue PeriodicExecutor. |
| 102 | |
| 103 | |
| 104 | class Topology: |
Tested by
no test coverage detected