SelfPrivacy/selfprivacy-rest-api
1
0
Fork 0
mirror of https://git.selfprivacy.org/SelfPrivacy/selfprivacy-rest-api.git synced 2024-11-10 13:03:11 +00:00
Code Issues Projects Releases Wiki Activity

refactor(backups): break out job logs status prefix

Browse source
This commit is contained in:
Houkime 2023-05-17 17:59:56 +00:00
parent deb857bca9
commit ddd2176a5d
1 changed files with 5 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
selfprivacy_api/jobs/__init__.py
View file

@ -26,6 +26,9 @@ from selfprivacy_api.utils.redis_pool import RedisPool
JOB_EXPIRATION_SECONDS = 10 * 24 * 60 * 60 # ten days JOB_EXPIRATION_SECONDS = 10 * 24 * 60 * 60 # ten days
STATUS_LOGS_PREFIX = "jobs_logs:status:"
PROGRESS_LOGS_PREFIX = "jobs_logs:progress:"
class JobStatus(str, Enum): class JobStatus(str, Enum):
""" """
@ -124,7 +127,7 @@ class Jobs:
@staticmethod @staticmethod
def reset_logs(): def reset_logs():
redis = RedisPool().get_connection() redis = RedisPool().get_connection()
for key in redis.keys("jobs_logs:" + "*"): for key in redis.keys(STATUS_LOGS_PREFIX + "*"):
redis.delete(key) redis.delete(key)
@staticmethod @staticmethod
@ -233,7 +236,7 @@ def _redis_key_from_uuid(uuid_string):
def _redis_log_key_from_uuid(uuid_string): def _redis_log_key_from_uuid(uuid_string):
return "jobs_logs:" + str(uuid_string) return STATUS_LOGS_PREFIX + str(uuid_string)
def _store_job_as_hash(redis, redis_key, model): def _store_job_as_hash(redis, redis_key, model):