Skip to content

Commit ea73a0e

Browse files
committed
undo accidental changes to test_redis_functiona.py
1 parent baf8d66 commit ea73a0e

File tree

1 file changed

+12
-12
lines changed

1 file changed

+12
-12
lines changed

tests/opentelemetry-docker-tests/tests/redis/test_redis_functional.py

Lines changed: 12 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -15,15 +15,15 @@
1515
import asyncio
1616
from time import time_ns
1717

18-
import valkey
19-
import valkey.asyncio
20-
from valkey.commands.search.field import (
18+
import redis
19+
import redis.asyncio
20+
from redis.commands.search.field import (
2121
TextField,
2222
VectorField,
2323
)
24-
from valkey.commands.search.indexDefinition import IndexDefinition, IndexType
25-
from valkey.commands.search.query import Query
26-
from valkey.exceptions import ResponseError
24+
from redis.commands.search.indexDefinition import IndexDefinition, IndexType
25+
from redis.commands.search.query import Query
26+
from redis.exceptions import ResponseError
2727

2828
from opentelemetry import trace
2929
from opentelemetry.instrumentation.redis import RedisInstrumentor
@@ -34,7 +34,7 @@
3434
class TestRedisInstrument(TestBase):
3535
def setUp(self):
3636
super().setUp()
37-
self.redis_client = valkey.Redis(port=6379)
37+
self.redis_client = redis.Redis(port=6379)
3838
self.redis_client.flushall()
3939
RedisInstrumentor().instrument(tracer_provider=self.tracer_provider)
4040

@@ -209,7 +209,7 @@ def test_parent(self):
209209
class TestRedisClusterInstrument(TestBase):
210210
def setUp(self):
211211
super().setUp()
212-
self.redis_client = valkey.cluster.RedisCluster(
212+
self.redis_client = redis.cluster.RedisCluster(
213213
host="localhost", port=7000
214214
)
215215
self.redis_client.flushall()
@@ -280,7 +280,7 @@ def async_call(coro):
280280
class TestAsyncRedisInstrument(TestBase):
281281
def setUp(self):
282282
super().setUp()
283-
self.redis_client = valkey.asyncio.Redis(port=6379)
283+
self.redis_client = redis.asyncio.Redis(port=6379)
284284
async_call(self.redis_client.flushall())
285285
RedisInstrumentor().instrument(tracer_provider=self.tracer_provider)
286286

@@ -470,7 +470,7 @@ def test_parent(self):
470470
class TestAsyncRedisClusterInstrument(TestBase):
471471
def setUp(self):
472472
super().setUp()
473-
self.redis_client = valkey.asyncio.cluster.RedisCluster(
473+
self.redis_client = redis.asyncio.cluster.RedisCluster(
474474
host="localhost", port=7000
475475
)
476476
async_call(self.redis_client.flushall())
@@ -593,7 +593,7 @@ def test_parent(self):
593593
class TestRedisDBIndexInstrument(TestBase):
594594
def setUp(self):
595595
super().setUp()
596-
self.redis_client = valkey.Redis(port=6379, db=10)
596+
self.redis_client = redis.Redis(port=6379, db=10)
597597
self.redis_client.flushall()
598598
RedisInstrumentor().instrument(tracer_provider=self.tracer_provider)
599599

@@ -626,7 +626,7 @@ def test_get(self):
626626
class TestRedisearchInstrument(TestBase):
627627
def setUp(self):
628628
super().setUp()
629-
self.redis_client = valkey.Redis(port=6379)
629+
self.redis_client = redis.Redis(port=6379)
630630
self.redis_client.flushall()
631631
self.embedding_dim = 256
632632
RedisInstrumentor().instrument(tracer_provider=self.tracer_provider)

0 commit comments

Comments
 (0)