carrotquest/django-clickhouse
1
1
Fork 0
mirror of https://github.com/carrotquest/django-clickhouse.git synced 2025-07-11 08:32:19 +03:00
Code Issues Packages Projects Releases Wiki Activity

Fix time between batches count

Browse Source
This commit is contained in:
M1ha 2018-12-19 12:58:34 +05:00
parent 36123db73e
commit 13b67ed77a
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/django_clickhouse/clickhouse_models.py
View File

@ -231,7 +231,7 @@ class ClickHouseModel(with_metaclass(ClickHouseModelMeta, InfiModel)):
if last_sync_time is None: if last_sync_time is None:
return True return True
return (last_sync_time - datetime.datetime.now()).total_seconds() >= cls.get_sync_delay() return (datetime.datetime.now() - last_sync_time).total_seconds() >= cls.get_sync_delay()
class ClickHouseMultiModel(ClickHouseModel): class ClickHouseMultiModel(ClickHouseModel):

4
tests/test_clickhouse_models.py
View File

@ -26,5 +26,5 @@ class ClickHouseModelTest(TestCase):
# Time has passed # Time has passed
sync_delay = ClickHouseTestModel.get_sync_delay() sync_delay = ClickHouseTestModel.get_sync_delay()
self.storage.set_last_sync_time(ClickHouseTestModel.get_import_key(), self.storage.set_last_sync_time(ClickHouseTestModel.get_import_key(),
datetime.datetime.now() - datetime.timedelta(seconds=sync_delay)) datetime.datetime.now() - datetime.timedelta(seconds=sync_delay + 1))
self.assertFalse(ClickHouseTestModel.need_sync()) self.assertTrue(ClickHouseTestModel.need_sync())