carrotquest/django-clickhouse
1
1
Fork 0
mirror of https://github.com/carrotquest/django-clickhouse.git synced 2024-11-22 09:06:43 +03:00
Code Issues Packages Projects Releases Wiki Activity

Refactoring

Browse Source
This commit is contained in:
M1ha 2019-01-10 17:29:41 +05:00
parent aed0928ba8
commit ec2f71fc78
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/django_clickhouse/tasks.py
View File

@ -11,7 +11,7 @@ from .utils import get_subclasses
@shared_task(queue=config.CELERY_QUEUE) @shared_task(queue=config.CELERY_QUEUE)
def sync_clickhouse_converter(cls): # type: (ClickHouseModel) -> None def sync_clickhouse_model(cls): # type: (ClickHouseModel) -> None
""" """
Syncs one batch of given ClickHouseModel Syncs one batch of given ClickHouseModel
:param cls: ClickHouseModel subclass :param cls: ClickHouseModel subclass
@ -41,4 +41,4 @@ def clickhouse_auto_sync():
if cls.need_sync(): if cls.need_sync():
# Даже если синхронизация вдруг не выполнится, не страшно, что мы установили период синхронизации # Даже если синхронизация вдруг не выполнится, не страшно, что мы установили период синхронизации
# Она выполнится следующей таской через интервал. # Она выполнится следующей таской через интервал.
sync_clickhouse_converter.delay(cls) sync_clickhouse_model.delay(cls)