️️
а как задать функцию, выполняющую таск с определенным именем?
🤔
Size: a a a
2020 June 10
<Ч
а чья?
Запланируй сам себе задачу поиска новых новых задач
T
Запланируй сам себе задачу поиска новых новых задач
ну так я могу просто циклом, да
T
если это я эту либу смотрел
add_job чет принимает функцию только как будто
T
что такое
textual reference to one - хзT
The func argument can be given either as a callable object or a textual reference in the package.module:some.object format, where the first half (separated by :) is an importable module and the second half is a reference to the callable object, relative to the module.лол
<Ч
ну так я могу просто циклом, да
Не понимаю тебя.
Делаешь функцию поиска новых задач она уже там берет коннекты к базе знает пароли и логины итд если она находит - планирует выполнение задач сразу и эту функцию планируешь планировщиком выполняться так часто как надо. Нет?
Делаешь функцию поиска новых задач она уже там берет коннекты к базе знает пароли и логины итд если она находит - планирует выполнение задач сразу и эту функцию планируешь планировщиком выполняться так часто как надо. Нет?
T
Не понимаю тебя.
Делаешь функцию поиска новых задач она уже там берет коннекты к базе знает пароли и логины итд если она находит - планирует выполнение задач сразу и эту функцию планируешь планировщиком выполняться так часто как надо. Нет?
Делаешь функцию поиска новых задач она уже там берет коннекты к базе знает пароли и логины итд если она находит - планирует выполнение задач сразу и эту функцию планируешь планировщиком выполняться так часто как надо. Нет?
ну
T
не знаю зачем тут вообще apscheduler тогда
T
я и без него могу тогда выполнять эти функции, если нашел
<Ч
А как по твоему?)
<Ч
я и без него могу тогда выполнять эти функции, если нашел
Может не сразу надо
️️
Может не сразу надо
асинцио калллейтер
<Ч
асинцио калллейтер
И успешно просрать при рестарте
️️
И успешно просрать при рестарте
🤔
T
А как по твоему?)
while True:
await asyncio.sleep(5)
async for job, in repo.get_jobs(conn):
if job.starttime<now():
await workers[job.name](job.data)
if job.is_periodic:
await repo.schedule_next(conn, job.id, job.get_next())
else:
await repo.mark_compleeted(conn, job.id)
️️
repo.schedule_next
️️
ждем тишкашудлер