diff options
Diffstat (limited to 'kombu/async/timer.py')
-rw-r--r-- | kombu/async/timer.py | 10 |
1 files changed, 8 insertions, 2 deletions
diff --git a/kombu/async/timer.py b/kombu/async/timer.py index 69d93a36..b67f4ddf 100644 --- a/kombu/async/timer.py +++ b/kombu/async/timer.py @@ -3,10 +3,10 @@ import heapq import sys -from collections import namedtuple from datetime import datetime from functools import total_ordering from time import monotonic +from typing import NamedTuple from weakref import proxy as weakrefproxy from vine.utils import wraps @@ -27,7 +27,13 @@ DEFAULT_MAX_INTERVAL = 2 EPOCH = datetime.utcfromtimestamp(0).replace(tzinfo=utc) IS_PYPY = hasattr(sys, 'pypy_version_info') -scheduled = namedtuple('scheduled', ('eta', 'priority', 'entry')) + +class scheduled(NamedTuple): + """Information about scheduled item.""" + + eta: float + priority: int + entry: 'Entry' def to_timestamp(d, default_timezone=utc, time=monotonic): |