|
@@ -36,6 +36,7 @@ DEBOUNCE_CACHE_KEY = lambda group_id: f"process-commit-context-{group_id}"
|
|
|
DEBOUNCE_PR_COMMENT_CACHE_KEY = lambda pullrequest_id: f"pr-comment-{pullrequest_id}"
|
|
|
DEBOUNCE_PR_COMMENT_LOCK_KEY = lambda pullrequest_id: f"queue_comment_task:{pullrequest_id}"
|
|
|
PR_COMMENT_TASK_TTL = timedelta(minutes=5).total_seconds()
|
|
|
+PR_COMMENT_WINDOW = 7 # days
|
|
|
|
|
|
logger = logging.getLogger(__name__)
|
|
|
|
|
@@ -83,7 +84,7 @@ def queue_comment_task_if_needed(
|
|
|
return
|
|
|
|
|
|
pr = pr_query.get()
|
|
|
- if pr.date_added >= datetime.now(tz=timezone.utc) - timedelta(days=30) and (
|
|
|
+ if pr.date_added >= datetime.now(tz=timezone.utc) - timedelta(days=PR_COMMENT_WINDOW) and (
|
|
|
not pr.pullrequestcomment_set.exists()
|
|
|
or group_owner.group_id not in pr.pullrequestcomment_set.get().group_ids
|
|
|
):
|