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

Fix time between batches count

Browse Source
This commit is contained in:
M1ha 2018-12-19 12:52:47 +05:00
parent 2dc8e7a270
commit 36123db73e
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/clickhouse_models.py
View File

@ -213,7 +213,7 @@ class ClickHouseModel(with_metaclass(ClickHouseModelMeta, InfiModel)):
with statsd.timer(statsd_key.format('steps.post_sync')): with statsd.timer(statsd_key.format('steps.post_sync')):
storage.post_sync(import_key) storage.post_sync(import_key)
storage.set_last_sync_time(import_key, now()) storage.set_last_sync_time(import_key, datetime.datetime.now())
except RedisLockTimeoutError: except RedisLockTimeoutError:
pass # skip this sync round if lock is acquired by another thread pass # skip this sync round if lock is acquired by another thread
@ -280,7 +280,7 @@ class ClickHouseMultiModel(ClickHouseModel):
with statsd.timer(statsd_key.format('steps.post_sync')): with statsd.timer(statsd_key.format('steps.post_sync')):
storage.post_sync(import_key) storage.post_sync(import_key)
storage.set_last_sync_time(import_key, now()) storage.set_last_sync_time(import_key, datetime.datetime.now())
except RedisLockTimeoutError: except RedisLockTimeoutError:
pass # skip this sync round if lock is acquired by another thread pass # skip this sync round if lock is acquired by another thread