SelfPrivacy/selfprivacy-rest-api
1
0
Fork 0
mirror of https://git.selfprivacy.org/SelfPrivacy/selfprivacy-rest-api.git synced 2024-11-26 14:01:30 +00:00
Code Issues Projects Releases Wiki Activity

refactor(backups): remove extraneous asserts from jobs

Browse source
This commit is contained in:
Houkime 2023-05-17 20:24:29 +00:00 committed by Inex Code
parent c8512eacdc
commit c5c41b3ced
1 changed files with 0 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
selfprivacy_api/jobs/__init__.py
View file

@ -134,8 +134,6 @@ class Jobs:
def log_status_update(job: Job, status: JobStatus): def log_status_update(job: Job, status: JobStatus):
redis = RedisPool().get_connection() redis = RedisPool().get_connection()
key = _status_log_key_from_uuid(job.uid) key = _status_log_key_from_uuid(job.uid)
if redis.exists(key):
assert redis.type(key) == "list"
redis.lpush(key, status.value) redis.lpush(key, status.value)
redis.expire(key, 10) redis.expire(key, 10)
@ -143,8 +141,6 @@ class Jobs:
def log_progress_update(job: Job, progress: int): def log_progress_update(job: Job, progress: int):
redis = RedisPool().get_connection() redis = RedisPool().get_connection()
key = _progress_log_key_from_uuid(job.uid) key = _progress_log_key_from_uuid(job.uid)
if redis.exists(key):
assert redis.type(key) == "list"
redis.lpush(key, progress) redis.lpush(key, progress)
redis.expire(key, 10) redis.expire(key, 10)