diff --git a/augur/tasks/github/pull_requests/tasks.py b/augur/tasks/github/pull_requests/tasks.py index b65da7f4f..21ef9d8eb 100644 --- a/augur/tasks/github/pull_requests/tasks.py +++ b/augur/tasks/github/pull_requests/tasks.py @@ -231,9 +231,14 @@ def collect_pull_request_review_comments(repo_git: str, full_collection: bool) - repo_id = get_repo_by_repo_git(repo_git).repo_id if not full_collection: - # subtract 2 days to ensure all data is collected - core_data_last_collected = (get_core_data_last_collected(repo_id) - timedelta(days=2)).replace(tzinfo=timezone.utc) - review_msg_url += f"?since={core_data_last_collected.isoformat()}" + last_collected_date = get_secondary_data_last_collected(repo_id) + + if last_collected_date: + # subtract 2 days to ensure all data is collected + core_data_last_collected = (last_collected_date - timedelta(days=2)).replace(tzinfo=timezone.utc) + review_msg_url += f"?since={core_data_last_collected.isoformat()}" + else: + logger.warning(f"core_data_last_collected is NULL for recollection on repo: {repo_git}") pr_reviews = get_pull_request_reviews_by_repo_id(repo_id)