This is an automated email from the ASF dual-hosted git repository.

gcruz pushed a commit to branch gc/8472
in repository https://gitbox.apache.org/repos/asf/allura.git

commit 27e1314efb3936773bb0a1294975503cd2940efd
Author: Guillermo Cruz <[email protected]>
AuthorDate: Tue Oct 4 15:10:50 2022 -0600

    [#8472] added extra debug info to find out why the query is returning zero 
results
---
 ForgeActivity/forgeactivity/main.py | 15 +++++++++++++++
 1 file changed, 15 insertions(+)

diff --git a/ForgeActivity/forgeactivity/main.py 
b/ForgeActivity/forgeactivity/main.py
index 774261c7e..f6f927383 100644
--- a/ForgeActivity/forgeactivity/main.py
+++ b/ForgeActivity/forgeactivity/main.py
@@ -257,6 +257,9 @@ class ForgeActivityController(BaseController):
         # but only within a small time window, so we can do efficient searching
         activity_ts = activity._id.generation_time
         time_window = timedelta(hours=1)
+        log.info(f"Time Window - {time_window} Activity TS {activity_ts}")
+        log.info(f"plus 1 hr {activity_ts + time_window}")
+        log.info(f"minus 1 hr {activity_ts - time_window}")
         all_copies = Activity.query.find({
             '_id': {
                 '$gt': ObjectId.from_datetime(activity_ts - time_window),
@@ -268,6 +271,18 @@ class ForgeActivityController(BaseController):
             'verb': activity.verb,
             'tags': activity.tags,
         }).all()
+        log.info("Delete Activity Query")
+        log.info({
+            '_id': {
+                '$gt': ObjectId.from_datetime(activity_ts - time_window),
+                '$lt': ObjectId.from_datetime(activity_ts + time_window),
+            },
+            'obj': activity.obj,
+            'target': activity.target,
+            'actor': activity.actor,
+            'verb': activity.verb,
+            'tags': activity.tags,
+        })
         log.info('Deleting %s copies of activity record: %s %s %s', 
len(all_copies),
                  activity.actor.activity_url, activity.verb, 
activity.obj.activity_url)
         for activity in all_copies:

Reply via email to