opensource/opentelemetry-python-contrib
1
0
Fork 0
mirror of https://github.com/open-telemetry/opentelemetry-python-contrib.git synced 2025-08-03 04:10:48 +08:00
Code Issues Packages Projects Releases Wiki Activity

Re-raise redis.WatchErrors when they occur (#2721)

Browse Source
This commit is contained in:
Chris Guidry
2024-07-18 13:11:04 -04:00
committed by GitHub
parent e6c27e0800
commit 05073008a3
2 changed files with 19 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
instrumentation/opentelemetry-instrumentation-redis/tests/test_redis.py
View File

@ -359,7 +359,7 @@ class TestRedis(TestBase):
def test_watch_error_sync(self):
def redis_operations():
try:
with pytest.raises(WatchError):
redis_client = fakeredis.FakeStrictRedis()
pipe = redis_client.pipeline(transaction=True)
pipe.watch("a")
@ -367,8 +367,6 @@ class TestRedis(TestBase):
pipe.multi()
pipe.set("a", "1")
pipe.execute()
except WatchError:
pass
redis_operations()
@ -400,7 +398,7 @@ class TestRedisAsync(TestBase, IsolatedAsyncioTestCase):
@pytest.mark.asyncio
async def test_watch_error_async(self):
async def redis_operations():
try:
with pytest.raises(WatchError):
redis_client = FakeRedis()
async with redis_client.pipeline(transaction=False) as pipe:
await pipe.watch("a")
@ -408,8 +406,6 @@ class TestRedisAsync(TestBase, IsolatedAsyncioTestCase):
pipe.multi()
await pipe.set("a", "1")
await pipe.execute()
except WatchError:
pass
await redis_operations()