1+ import logging
12import os
23import subprocess
3- import time
44from datetime import datetime , timezone
55
66import pytest
1111from redisvl .redis .utils import array_to_buffer
1212from redisvl .utils .vectorize import HFTextVectorizer
1313
14+ logger = logging .getLogger (__name__ )
15+
1416
1517@pytest .fixture (scope = "session" )
1618def worker_id (request ):
@@ -94,14 +96,18 @@ def redis_cluster_container(worker_id):
9496 )
9597
9698 if result .returncode != 0 :
97- print (f"Docker Compose up failed with exit code { result .returncode } " )
99+ logger . error (f"Docker Compose up failed with exit code { result .returncode } " )
98100 if result .stdout :
99- print (f"STDOUT: { result .stdout .decode ('utf-8' , errors = 'replace' )} " )
101+ logger .error (
102+ f"STDOUT: { result .stdout .decode ('utf-8' , errors = 'replace' )} "
103+ )
100104 if result .stderr :
101- print (f"STDERR: { result .stderr .decode ('utf-8' , errors = 'replace' )} " )
105+ logger .error (
106+ f"STDERR: { result .stderr .decode ('utf-8' , errors = 'replace' )} "
107+ )
102108
103109 # Try to get logs for more details
104- print ("Attempting to fetch container logs..." )
110+ logger . info ("Attempting to fetch container logs..." )
105111 try :
106112 logs_result = subprocess .run (
107113 [
@@ -116,11 +122,11 @@ def redis_cluster_container(worker_id):
116122 capture_output = True ,
117123 text = True ,
118124 )
119- print ("Docker Compose logs:\n " , logs_result .stdout )
125+ logger . info ("Docker Compose logs:\n " , logs_result .stdout )
120126 if logs_result .stderr :
121- print ("Docker Compose logs stderr:\n " , logs_result .stderr )
127+ logger . error ("Docker Compose logs stderr:\n " , logs_result .stderr )
122128 except Exception as log_e :
123- print (f"Failed to get Docker Compose logs: { repr (log_e )} " )
129+ logger . error (f"Failed to get Docker Compose logs: { repr (log_e )} " )
124130
125131 # Now raise the exception with the original result
126132 raise subprocess .CalledProcessError (
@@ -150,7 +156,7 @@ def redis_cluster_container(worker_id):
150156 capture_output = True ,
151157 )
152158 except Exception as e :
153- print (f"Error during cleanup: { repr (e )} " )
159+ logger . error (f"Error during cleanup: { repr (e )} " )
154160
155161
156162@pytest .fixture (scope = "session" )
0 commit comments