Fix async feature flag mypy violations

Author: marandaneto

posthog/async_client.py

@@ -627,7 +627,7 @@ async def _enqueue(self, msg, disable_geoip) -> Optional[str]:  # type: ignore[o
             self.log.warning("analytics-python async queue is full")
             return None
 
-    async def get_flags_decision(
+    async def get_flags_decision(  # type: ignore[override]
         self,
         distinct_id=None,
         groups: Optional[Mapping[str, Union[str, int]]] = None,
@@ -651,7 +651,7 @@ async def get_flags_decision(
             self.log.exception("Unable to get feature flags: %s", err)
             return normalize_flags_response({})
 
-    async def _get_flags_decision(
+    async def _get_flags_decision(  # type: ignore[override]
         self,
         distinct_id=None,
         groups: Optional[Mapping[str, Union[str, int]]] = None,
@@ -863,7 +863,7 @@ async def _ensure_feature_flags_loaded_for_local_evaluation(self) -> None:
         if self.feature_flags is None and self.personal_api_key:
             await self.load_feature_flags()
 
-    async def _get_feature_flag_details_from_server(
+    async def _get_feature_flag_details_from_server(  # type: ignore[override]
         self,
         key: str,
         distinct_id,
@@ -889,7 +889,7 @@ async def _get_feature_flag_details_from_server(
         flag_details = flags.get(key) if flags else None
         return flag_details, request_id, evaluated_at, errors_while_computing
 
-    async def get_feature_flag_result(
+    async def get_feature_flag_result(  # type: ignore[override]
         self,
         key: str,
         distinct_id,
@@ -914,7 +914,7 @@ async def get_feature_flag_result(
             device_id=device_id,
         )
 
-    async def _get_feature_flag_result(
+    async def _get_feature_flag_result(  # type: ignore[override]
         self,
         key: str,
         distinct_id,
@@ -1041,7 +1041,7 @@ async def _get_feature_flag_result(
 
         return flag_result
 
-    async def get_feature_flag(
+    async def get_feature_flag(  # type: ignore[override]
         self,
         key: str,
         distinct_id,
@@ -1073,7 +1073,9 @@ async def get_feature_flag(
         )
         return result.get_value() if result else None
 
-    async def feature_enabled(self, key: str, distinct_id, **kwargs) -> Optional[bool]:
+    async def feature_enabled(  # type: ignore[override]
+        self, key: str, distinct_id, **kwargs
+    ) -> Optional[bool]:
         warnings.warn(
             "`feature_enabled` is deprecated and will be removed in a future major version. "
             "Use `await posthog.evaluate_flags(distinct_id, ...)` and call `flags.is_enabled(key)` instead.",
@@ -1118,7 +1120,7 @@ async def get_feature_flag_payload(
         )
         return result.payload if result else None
 
-    async def get_all_flags(
+    async def get_all_flags(  # type: ignore[override]
         self,
         distinct_id,
         *,
@@ -1142,7 +1144,7 @@ async def get_all_flags(
         )
         return response["featureFlags"]
 
-    async def get_all_flags_and_payloads(
+    async def get_all_flags_and_payloads(  # type: ignore[override]
         self,
         distinct_id,
         *,
@@ -1197,7 +1199,7 @@ async def get_all_flags_and_payloads(
                 )
         return response
 
-    async def evaluate_flags(
+    async def evaluate_flags(  # type: ignore[override]
         self,
         distinct_id=None,
         *,
@@ -1449,7 +1451,7 @@ async def _capture_feature_flag_called_if_needed_async(
             "$feature_flag_called",
             distinct_id=distinct_id,
             properties=properties,
-            groups=groups or {},
+            groups={str(k): str(v) for k, v in (groups or {}).items()},
             disable_geoip=disable_geoip,
         )
         reported_flags.add(feature_flag_reported_key)