From bb3ba34f96049ff4173d283a9152650c34e5d6fa Mon Sep 17 00:00:00 2001 From: lwl0608 Date: Tue, 6 Feb 2024 02:22:34 +0800 Subject: [PATCH] fix --- cronjob/media/compress.py | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/cronjob/media/compress.py b/cronjob/media/compress.py index b084148..0998576 100644 --- a/cronjob/media/compress.py +++ b/cronjob/media/compress.py @@ -145,6 +145,8 @@ class S: bulk_reqs = list() + status = 100 + # 先下载到本地,源文件 imgprod/a4/98/22b4-391d-445d-834c-5048fb77653c oss_src_download_path = cur_dir + src_id_python_type + ".{}".format(fmt) try: @@ -156,6 +158,7 @@ class S: # 720P uo720 = self.deal_one(oss_src_id, oss_src_download_path, fmt, Resize720P) if not uo720: + status = 101 logger.Error("deal_one 720 error, oss_src_id: {}".format(oss_src_id)) else: bulk_reqs.append(uo720) @@ -163,6 +166,7 @@ class S: # 1080P uo1080 = self.deal_one(oss_src_id, oss_src_download_path, fmt, Resize1080P) if not uo1080: + status = 101 logger.Error("deal_one 1080 error, oss_src_id: {}".format(oss_src_id)) else: bulk_reqs.append(uo1080) @@ -170,6 +174,7 @@ class S: # 1440P uo1440 = self.deal_one(oss_src_id, oss_src_download_path, fmt, Resize1440P) if not uo1440: + status = 101 logger.Error("deal_one 1440 error, oss_src_id: {}".format(oss_src_id)) else: bulk_reqs.append(uo1440) @@ -182,7 +187,7 @@ class S: "$set": { "size_src": src_size, "resize_t": int(time.time()), - "status": 100 + "status": status } } bulk_reqs.append(UpdateOne(q1, up1))