import asyncio import aioredis import elasticapm REDIS_URL = "redis://localhost:6379" async def main(): elasticapm.instrument() client = await aioredis.create_redis_pool(REDIS_URL) elastic_apm_client = elasticapm.Client() elastic_apm_client.begin_transaction("redis-ping") try: assert await client.ping() == b"PONG" finally: client.close() await client.wait_closed() elastic_apm_client.end_transaction("redis-ping") if __name__ == "__main__": asyncio.run(main())

Traceback (most recent call last): File "<...>/test.py", line 24, in <module> asyncio.run(main()) File "/usr/local/lib/python3.8/asyncio/runners.py", line 44, in run return loop.run_until_complete(main) File "/usr/local/lib/python3.8/asyncio/base_events.py", line 616, in run_until_complete return future.result() File "<...>/test.py", line 17, in main assert await client.ping() == b"PONG" File "<...>/venv/lib/python3.8/site-packages/aioredis/commands/__init__.py", line 114, in ping return self.execute('PING', *args, encoding=encoding) File "<...>/venv/lib/python3.8/site-packages/aioredis/commands/__init__.py", line 51, in execute return self._pool_or_conn.execute(command, *args, **kwargs) File "<...>/venv/lib/python3.8/site-packages/elasticapm/instrumentation/packages/base.py", line 210, in call_if_sampling return self.call(module, method, wrapped, instance, args, kwargs) File "<...>/venv/lib/python3.8/site-packages/elasticapm/instrumentation/packages/asyncio/aioredis.py", line 46, in call wrapped_name = args[0].decode() AttributeError: 'str' object has no attribute 'decode'