|
14 | 14 | _logger = logging.getLogger(__name__) |
15 | 15 |
|
16 | 16 |
|
17 | | -class PriorityQueue(object): |
| 17 | +class PriorityQueue: |
18 | 18 | """A priority queue that supports removing arbitrary objects. |
19 | 19 |
|
20 | 20 | Adding an object already in the queue is a no op. |
@@ -103,7 +103,7 @@ def pop(self): |
103 | 103 |
|
104 | 104 |
|
105 | 105 | @total_ordering |
106 | | -class ChannelJob(object): |
| 106 | +class ChannelJob: |
107 | 107 | """A channel job is attached to a channel and holds the properties of a |
108 | 108 | job that are necessary to prioritise them. |
109 | 109 |
|
@@ -205,7 +205,7 @@ def __lt__(self, other): |
205 | 205 | return self.sorting_key() < other.sorting_key() |
206 | 206 |
|
207 | 207 |
|
208 | | -class ChannelQueue(object): |
| 208 | +class ChannelQueue: |
209 | 209 | """A channel queue is a priority queue for jobs. |
210 | 210 |
|
211 | 211 | Jobs with an eta are set aside until their eta is past due, at |
@@ -334,7 +334,7 @@ def get_wakeup_time(self, wakeup_time=0): |
334 | 334 | return wakeup_time |
335 | 335 |
|
336 | 336 |
|
337 | | -class Channel(object): |
| 337 | +class Channel: |
338 | 338 | """A channel for jobs, with a maximum capacity. |
339 | 339 |
|
340 | 340 | When jobs are created by queue_job modules, they may be associated |
@@ -581,7 +581,7 @@ def split_strip(s, sep, maxsplit=-1): |
581 | 581 | return [x.strip() for x in s.split(sep, maxsplit)] |
582 | 582 |
|
583 | 583 |
|
584 | | -class ChannelManager(object): |
| 584 | +class ChannelManager: |
585 | 585 | """High level interface for channels |
586 | 586 |
|
587 | 587 | This class handles: |
|
0 commit comments