(beam) branch master updated: Filter out old actions runs from dashboard (#32347)

[da...@apache.org]

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

damccorm pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new a85b0a636dc Filter out old actions runs from dashboard (#32347)
a85b0a636dc is described below

commit a85b0a636dc54483e20f981e3ee5b2b3369578c6
Author: Danny McCormick <da...@google.com>
AuthorDate: Wed Aug 28 17:26:58 2024 +0100

    Filter out old actions runs from dashboard (#32347)
---
 .test-infra/metrics/sync/github/github_runs_prefetcher/code/main.py | 3 +++
 1 file changed, 3 insertions(+)

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 e8fe60b4a7d..fd4a5e713fe 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
@@ -307,6 +307,8 @@ async def fetch_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)
+    earliest_run_creation_date = start.strftime('%Y-%m-%d')
     semaphore = asyncio.Semaphore(concurrent_requests)
 
     print("Start fetching recent workflow runs")
@@ -338,6 +340,7 @@ async def fetch_workflow_runs():
                     "page": page,
                     "per_page": number_of_entries_per_page,
                     "exclude_pull_requests": "true",
+                    "created": f'>={earliest_run_creation_date}',
                 }
                 workflow_run_tasks.append(fetch(runs_url, semaphore, params, headers))
                 page += 1