Fix errors

ddapm_test_agent/agent.py

@@ -435,7 +435,7 @@ async def _apmtelemetry_by_session(self, token: Optional[str]) -> List[Telemetry
         events: List[TelemetryEvent] = []
         for req in self._requests_by_session(token):
             if req.match_info.handler == self.handle_v2_apmtelemetry:
-                events.append(v2_apmtelemetry_decode(await req.read()))
+                events.append(await v2_apmtelemetry_decode_request(req, await req.read()))
 
         # TODO: Sort the events?
         return events

ddapm_test_agent/apmtelemetry.py

@@ -1,15 +1,17 @@
 import asyncio
 import json
 import logging
-from aiohttp.web import Request
 from typing import Any
 from typing import Dict
 from typing import cast
 
-log = logging.getLogger(__name__)
+from aiohttp.web import Request
 
+
+log = logging.getLogger(__name__)
 TelemetryEvent = Dict[str, Any]
 
+
 async def v2_decode_request(request: Request, data: bytes) -> TelemetryEvent:
     headers = request.headers
 
@@ -20,7 +22,7 @@ async def v2_decode_request(request: Request, data: bytes) -> TelemetryEvent:
     if duration > 0:
         log.info("Stalling for %r seconds.", duration)
         await asyncio.sleep(duration)
-    v2_decode(data)
+    return v2_decode(data)
 
 
 def v2_decode(data: bytes) -> TelemetryEvent: