google синхронизация

This commit is contained in:
2024-02-12 22:49:16 +03:00
parent 9ba42aae9f
commit a4f8bce657
3 changed files with 133 additions and 2 deletions

View File

@@ -4,7 +4,7 @@ from celery import Celery
from fastfood.config import settings
from .updater import main
from .updater import main, main_gsheets
loop = asyncio.get_event_loop()
@@ -23,6 +23,26 @@ celery_app.conf.beat_schedule = {
},
}
celery_app_google = Celery(
'tasks',
broker=settings.REBBITMQ_URL,
backend='rpc://',
include=['bg_tasks.bg_task'],
)
celery_app_google.conf.beat_schedule = {
'run-task-every-15-seconds': {
'task': 'bg_tasks.bg_task.periodic_task_google',
'schedule': 30.0,
},
}
@celery_app_google.task
def periodic_task_google() -> None:
result = loop.run_until_complete(main_gsheets())
return result
@celery_app.task
def periodic_task() -> None: