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

Fix in counter

Browse Source
This commit is contained in:
M1ha 2019-01-18 18:01:18 +05:00
parent 9bc6c6154b
commit d8dccf209d
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/django_clickhouse/storages.py
View File

@ -233,11 +233,10 @@ class RedisStorage(Storage):
else: else:
batch_size = 0 batch_size = 0
self.post_batch_removed(import_key, batch_size)
# unblock lock after sync completed # unblock lock after sync completed
lock_pid_key = self.REDIS_KEY_LOCK_PID.format(import_key=import_key) lock_pid_key = self.REDIS_KEY_LOCK_PID.format(import_key=import_key)
self._redis.delete(lock_pid_key) self._redis.delete(lock_pid_key)
self.post_batch_removed(import_key, batch_size)
self.get_lock(import_key, **kwargs).release() self.get_lock(import_key, **kwargs).release()
logger.info('django-clickhouse: synced %d items (key: %s)' % (batch_size, import_key)) logger.info('django-clickhouse: synced %d items (key: %s)' % (batch_size, import_key))