fix: Task processor overload when handling high volume SDK traffic (#5358)

Author: khvn26

api/app_analytics/cache.py

@@ -20,7 +20,7 @@ def __init__(self) -> None:
 
     def _flush(self) -> None:
         for key, value in self._cache.items():
-            track_request.delay(
+            track_request.run_in_thread(
                 kwargs={
                     "resource": key[0].value,
                     "host": key[1],

api/app_analytics/services.py

@@ -20,7 +20,7 @@ def track_usage_by_resource_host_and_environment(
                 environment_key=environment_key,
             )
         else:
-            track_request.delay(
+            track_request.run_in_thread(
                 kwargs={
                     "resource": resource.value,
                     "host": host,

api/tests/unit/app_analytics/test_middleware.py

@@ -78,7 +78,7 @@ def test_api_usage_middleware__no_cache__calls_expected(
     middleware(request)
 
     # Then
-    mocked_track_request.delay.assert_called_once_with(
+    mocked_track_request.run_in_thread.assert_called_once_with(
         kwargs={
             "resource": Resource.get_from_name(resource_name),
             "environment_key": environment_key,

api/tests/unit/app_analytics/test_unit_app_analytics_cache.py

@@ -72,7 +72,7 @@ def test_api_usage_cache(
                     }
                 )
             )
-        mocked_track_request_task.delay.assert_has_calls(expected_calls)
+        mocked_track_request_task.run_in_thread.assert_has_calls(expected_calls)
 
         # Next, let's reset the mock
         mocked_track_request_task.reset_mock()