fix: 修改属性名称以提高代码可读性并修正回滚逻辑
This commit is contained in:
parent
eacc30979c
commit
f067fba177
4
DB.py
4
DB.py
@ -23,7 +23,7 @@ class DBVidcon:
|
|||||||
|
|
||||||
def __init__(self):
|
def __init__(self):
|
||||||
self.list_key = "video_kw_queue"
|
self.list_key = "video_kw_queue"
|
||||||
self.record_list_key = "error_save_queue"
|
self.error_list_key = "error_save_queue"
|
||||||
self.urgent_list_key = "video_urgent_queue"
|
self.urgent_list_key = "video_urgent_queue"
|
||||||
self.conn = pymysql.connect(**self._MYSQL_CONF)
|
self.conn = pymysql.connect(**self._MYSQL_CONF)
|
||||||
self.cursor = self.conn.cursor()
|
self.cursor = self.conn.cursor()
|
||||||
@ -121,7 +121,7 @@ class DBVidcon:
|
|||||||
def rollback_records(self, raws):
|
def rollback_records(self, raws):
|
||||||
if isinstance(raws, str):
|
if isinstance(raws, str):
|
||||||
raws = [raws]
|
raws = [raws]
|
||||||
self.redis.lpush(self.record_list_key, *raws)
|
self.redis.lpush(self.urgent_list_key, *raws)
|
||||||
|
|
||||||
def rollback_urgent(self, raws):
|
def rollback_urgent(self, raws):
|
||||||
if isinstance(raws, str):
|
if isinstance(raws, str):
|
||||||
|
Loading…
x
Reference in New Issue
Block a user