celery.utils.timer2

Планировщик функций Python.

classcelery.utils.timer2.Entry(fun, args=None, kwargs=None)

Запись планировщика.

args

cancel()

canceled

propertycancelled

fun

kwargs

tref

celery.utils.timer2.Schedule

псевдоним для Timer

classcelery.utils.timer2.Timer(schedule:Timer|None=None, on_error:Callable[[Exception],None]|None=None, on_tick:Callable[[float],None]|None=None, on_start:Callable[[Timer],None]|None=None, max_interval:float|None=None, **kwargs:Any)

Поток таймера.

Примечание

Используется только для транспортов, не поддерживающих AsyncIO.

classEntry(fun, args=None, kwargs=None)

Запись планировщика.

args

cancel()

canceled

propertycancelled

fun

kwargs

tref

Schedule

псевдоним для Timer

call_after(*args:Any, **kwargs:Any) → Entry

call_at(*args:Any, **kwargs:Any) → Entry

call_repeatedly(*args:Any, **kwargs:Any) → Entry

cancel(tref:Entry) → None

clear() → None

empty() → bool

ensure_started() → None

enter(entry:Entry, eta:float, priority:int|None=None) → Entry

enter_after(*args:Any, **kwargs:Any) → Entry

exit_after(secs:float, priority:int=10) → None

next() → float|None

on_tick:Callable[[float],None]|None=None

propertyqueue:list

run() → None

Метод, описывающий активность потока.

Этот метод можно переопределить в подклассе. Стандартный метод run() вызывает вызываемый объект, переданный конструктору объекта в качестве аргумента target (если он указан), с позиционными и именованными аргументами, взятыми соответственно из аргументов args и kwargs.

running:bool=False

stop() → None

celery.utils.timer2.to_timestamp(d, default_timezone=zoneinfo.ZoneInfo(key='UTC'), time=<built-in function monotonic>)

Преобразовать datetime в метку времени.

Если d уже является меткой времени, будет использовано это значение.