diff --git a/.test-infra/metrics/sync/github/github_runs_prefetcher/code/main.py b/.test-infra/metrics/sync/github/github_runs_prefetcher/code/main.py
index fd4a5e713fe0..292ad618b792 100644
--- a/.test-infra/metrics/sync/github/github_runs_prefetcher/code/main.py
+++ b/.test-infra/metrics/sync/github/github_runs_prefetcher/code/main.py
@@ -158,8 +158,8 @@ def filter_workflow_runs(run, issue):
     if not len(workflow.runs):
         return False
 
-    three_months_ago_datetime = datetime.now() - timedelta(days=90)
-    workflow_runs = [run for run in workflow.runs if run.started_at > three_months_ago_datetime]
+    one_month_ago_datetime = datetime.now() - timedelta(days=30)
+    workflow_runs = [run for run in workflow.runs if run.started_at > one_month_ago_datetime]
 
     url = f"https://api.github.com/repos/{GIT_ORG}/beam/issues"
     headers = {"Authorization": get_token()}
@@ -307,7 +307,7 @@ def append_workflow_runs(workflow, runs):
     number_of_entries_per_page = 100  # The number of results per page (max 100)
     params = {"branch": "master", "page": page, "per_page": number_of_entries_per_page}
     concurrent_requests = 30  # Number of requests to send simultaneously
-    start = datetime.now() - timedelta(days=90)
+    start = datetime.now() - timedelta(days=30)
     earliest_run_creation_date = start.strftime('%Y-%m-%d')
     semaphore = asyncio.Semaphore(concurrent_requests)