From 04f5790d4fbb9bf3e92cd60deebc807160fafb64 Mon Sep 17 00:00:00 2001 From: Watchful1 Date: Sat, 9 Nov 2024 23:13:00 -0800 Subject: [PATCH] Typo --- personal/combine/merge_and_backfill.py | 2 +- personal/process_month.py | 3 +++ 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/personal/combine/merge_and_backfill.py b/personal/combine/merge_and_backfill.py index cc4f374..ee7b91c 100644 --- a/personal/combine/merge_and_backfill.py +++ b/personal/combine/merge_and_backfill.py @@ -121,7 +121,7 @@ def query_pushshift(ids, bearer, object_type, pushshift_token_function): discord_logging.flush_discord() sys.exit(1) if current_attempt > 0: - log.info(f"Pushshift call succeeded after {i} retries") + log.info(f"Pushshift call succeeded after {current_attempt} retries") return response.json()['data'], bearer diff --git a/personal/process_month.py b/personal/process_month.py index 34e1858..6da32e3 100644 --- a/personal/process_month.py +++ b/personal/process_month.py @@ -10,6 +10,7 @@ import time import logging.handlers import requests import praw +import traceback from datetime import datetime, timedelta import multiprocessing_logging @@ -228,6 +229,8 @@ def process(queue, base_folder, month, file_type, type_stages, reddit_username, # for stage, status in type_stages.items(): # log.info(f"{file_type} {stage}: {status}") except Exception as err: + log.warning(f"Error in {type}: {err}") + log.warning(traceback.format_exc()) queue.put((file_type, "error", str(err))) discord_logging.flush_discord() # for stage, status in type_stages.items():