fix: new ta task flake processing (#1221)

Author: joseph-sentry

tasks/process_flakes.py

@@ -94,7 +94,7 @@ def run_impl(
                             process_func(repo_id, commit_sha.decode())
 
         except LockError:
-            log.warning("Unable to acquire process flakeslock for key %s.", lock_name)
+            log.warning("Unable to acquire process flakes lock for key %s.", lock_name)
             return {"successful": False}
 
         return {"successful": True}

tasks/test_results_finisher.py

@@ -26,6 +26,7 @@
     read_failures_summary,
     read_tests_totals_summary,
 )
+from services.test_analytics.ta_process_flakes import KEY_NAME
 from services.test_results import (
     FinisherResult,
     FlakeInfo,
@@ -143,7 +144,7 @@ def old_impl(
         commit: Commit,
         chain_result: bool,
         commit_yaml: UserYaml,
-        impl_type: Literal["old", "both", "new"],
+        impl_type: Literal["old", "both"],
     ) -> FinisherResult:
         repoid = repo.repoid
         commitid = commit.commitid
@@ -152,6 +153,8 @@ def old_impl(
         if should_do_flaky_detection(repo, commit_yaml):
             if commit.merged is True or commit.branch == repo.branch:
                 redis_client.lpush(NEW_KEY.format(repo.repoid), commit.commitid)
+                if impl_type == "both":
+                    redis_client.lpush(KEY_NAME.format(repo.repoid), commit.commitid)
                 self.app.tasks[process_flakes_task_name].apply_async(
                     kwargs=dict(
                         repo_id=repoid,