|
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