fix: remove process flakes commit_sha arg

this is the final step in moving the process flakes task to using the
new method of fetching commit shas from redis. Since all TA finisher
tasks are writing to redis using the new method, the process flakes
task doesn't need to read the old method anymore, so we can remove
that.

Author: joseph-sentry

tasks/process_flakes.py

@@ -1,5 +1,5 @@
 import logging
-from typing import Any, Literal
+from typing import Any, Literal, cast
 
 from redis import Redis
 from redis.exceptions import LockError
@@ -21,21 +21,12 @@
 OLD_KEY = "flake_uploads:{}"
 
 
-def get_redis_val(redis_client: Redis, repo_id: int) -> tuple[list[bytes], bool]:
-    commit_ids = redis_client.lpop(NEW_KEY.format(repo_id), 10)
+def get_redis_val(redis_client: Redis, repo_id: int) -> list[bytes]:
+    commit_ids = cast(list[bytes], redis_client.lpop(NEW_KEY.format(repo_id), 10))
     if commit_ids is None:
         commit_ids = []
 
-    current_commit = False
-    with redis_client.pipeline() as pipe:
-        # can't use getdel because the value of the key is not a string
-        pipe.get(OLD_KEY.format(repo_id))
-        pipe.delete(OLD_KEY.format(repo_id))
-        commit_id = pipe.execute()
-        if commit_id[0] is not None:
-            current_commit = True
-
-    return commit_ids, current_commit
+    return commit_ids
 
 
 class ProcessFlakesTask(BaseCodecovTask, name=process_flakes_task_name):
@@ -48,7 +39,6 @@ def run_impl(
         _db_session: Session,
         *,
         repo_id: int,
-        commit_id: str,
         impl_type: Literal["old", "new", "both"] = "old",
         **kwargs: Any,
     ):
@@ -77,7 +67,7 @@ def run_impl(
         """
         log.info(
             "Received process flakes task",
-            extra=dict(repoid=repo_id, commit=commit_id),
+            extra=dict(repoid=repo_id),
         )
 
         if impl_type == "new" or impl_type == "both":
@@ -97,15 +87,12 @@ def run_impl(
                 blocking_timeout=3,
             ):
                 while True:
-                    commit_ids, current_commit = get_redis_val(redis_client, repo_id)
-                    if not commit_ids and not current_commit:
+                    commit_shas = get_redis_val(redis_client, repo_id)
+                    if not commit_shas:
                         break
 
-                    for commitid in commit_ids:
-                        process_func(repo_id, commitid.decode())
-
-                    if current_commit:
-                        process_func(repo_id, commit_id)
+                    for commit_sha in commit_shas:
+                        process_func(repo_id, commit_sha.decode())
 
         except LockError:
             log.warning("Unable to acquire process flakeslock for key %s.", lock_name)