clean up excessive logging

portal/trigger_states/empro_states.py

@@ -229,7 +229,6 @@ def evaluate_triggers(qnr):
         # transition and persist state
         sm.processed_triggers()
         ts.insert(from_copy=True)
-        current_app.logger.debug(f"QQQ{ts.user_id} post processed_triggers")
         current_app.logger.debug(
             "persist-trigger_states-new record state change to 'processed' "
             f"from evaluate_triggers() {ts}")
@@ -261,29 +260,20 @@ def fire_trigger_events():
     now = datetime.utcnow()
 
     def delay_processing(ts):
-        current_app.logger.debug(f"QQQ{ts.user_id} enter sequential_threshold_reached")
         """Give user time to respond to opt-out prompt if applicable"""
         if not ts.sequential_threshold_reached():
             # not applicable unless at least one domain has adequate count
-            current_app.logger.debug(f"QQQ{ts.user_id} sequential_threshold_reached false, bail")
             return
 
         if ts.opted_out_domains():
             # user must have already replied, if opted out of at least one
-            current_app.logger.debug(f"QQQ{ts.user_id} user already opted out")
             return
 
         # check time since row transitioned to current state.  delay
         # till threshold reached
-        now = datetime.utcnow()
-        current_app.logger.debug(f"QQQ{ts.user_id} row timestamp: {ts.timestamp} now: {now}")
         filed_n_delay = ts.timestamp + timedelta(seconds=OPT_OUT_DELAY)
-        current_app.logger.debug(f"QQQ{ts.user_id} {filed_n_delay} > {now} : {filed_n_delay < now}")
-        current_app.logger.debug(f"QQQ{ts.user_id} {filed_n_delay.tzinfo}")
-        if filed_n_delay > now:
-            current_app.logger.debug(f"QQQ{ts.user_id} return True from delay_processing")
+        if filed_n_delay > datetime.utcnow():
             return True
-        current_app.logger.debug(f"QQQ{ts.user_id} return None from delay_processing")
 
     def send_n_report(em, context, record):
         """Send email, append success/fail w/ context to record"""
@@ -413,9 +403,7 @@ def process_pending_actions(ts):
     # evaluated
     for ts in TriggerState.query.filter(TriggerState.state == 'processed'):
         if delay_processing(ts):
-            current_app.logger.debug(f"QQQ{ts.user_id} delayed!!")
             continue
-        current_app.logger.debug(f"QQQ{ts.user_id} NOT delayed!!")
         try:
             with TimeoutLock(
                     key=EMPRO_LOCK_KEY.format(user_id=ts.user_id),