diff --git a/ops/ad_produce.py b/ops/ad_produce.py index aadcd30..6644d8f 100644 --- a/ops/ad_produce.py +++ b/ops/ad_produce.py @@ -165,8 +165,11 @@ def produce_task(): except Exception: log.error(f"split {line} failed!", exc_info=True) run_status = 0 + log.info(f"produce {len(all)} 2 redis!") #log.info("end produce cache!") my_redis.set("ad_produce", run_status) now = datetime.datetime.now() timestamp = int(datetime.datetime.timestamp(now)) my_redis.set("ad_produce_time", timestamp) + del data + del all