diff --git a/ddapm_test_agent/tracerflare.py b/ddapm_test_agent/tracerflare.py index 491415b..26fe6e6 100644 --- a/ddapm_test_agent/tracerflare.py +++ b/ddapm_test_agent/tracerflare.py @@ -1,6 +1,7 @@ import base64 from typing import Dict +from aiohttp import BodyPartReader from aiohttp import MultipartReader from aiohttp import StreamReader from aiohttp.web import Request @@ -18,7 +19,7 @@ async def v1_decode(request: Request, data: bytes) -> TracerFlareEvent: stream.feed_data(data) stream.feed_eof() async for part in MultipartReader(request.headers, stream): - if part.name is not None: + if isinstance(part, BodyPartReader) and part.name: if part.name == "flare_file": tracer_flare[part.name] = base64.b64encode(await part.read()).decode("ascii") else: