Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Multithread open source tests #882

Draft
wants to merge 18 commits into
base: mainline
Choose a base branch
from
Prev Previous commit
Next Next commit
try lock
  • Loading branch information
RaynorChavez committed Jun 27, 2024
commit 7bd4e812d0bfd3b0cf5f60243484afc117171711
16 changes: 8 additions & 8 deletions tests/marqo_test.py
Original file line number Diff line number Diff line change
Expand Up @@ -35,15 +35,15 @@ def configure_request_metrics(cls):
@classmethod
def tearDownClass(cls):
cls.patcher.stop()
"""

# Lock method
if cls.indexes:
with cls.delete_lock:
try:
cls.index_management.batch_delete_indexes(cls.indexes)
except Exception as e:
print(f"Error deleting indexes: {e}")"""
max_retries = 5
print(f"Error deleting indexes: {e}")
"""max_retries = 5
retry_wait_time = 90 # seconds
if cls.indexes:
for attempt in range(max_retries):
Expand All @@ -54,7 +54,7 @@ def tearDownClass(cls):
if attempt < max_retries - 1:
time.sleep(retry_wait_time)
else:
raise e
raise e"""

@classmethod
def setUpClass(cls) -> None:
Expand All @@ -79,7 +79,7 @@ def setUpClass(cls) -> None:
@classmethod
def create_indexes(cls, index_requests: List[MarqoIndexRequest]) -> List[MarqoIndex]:
# Retries. If fail, wait for 30 seconds and retry request up to 5 tries
"""

# Lock method
with cls.create_lock:
try:
Expand All @@ -88,8 +88,8 @@ def create_indexes(cls, index_requests: List[MarqoIndexRequest]) -> List[MarqoIn
return indexes
except Exception as e:
print(f"Error creating indexes: {e}")
"""
max_retries = 5

"""max_retries = 5
retry_wait_time = 90 # seconds
for attempt in range(max_retries):
try:
Expand All @@ -100,7 +100,7 @@ def create_indexes(cls, index_requests: List[MarqoIndexRequest]) -> List[MarqoIn
if attempt < max_retries - 1:
time.sleep(retry_wait_time)
else:
raise e
raise e"""
#indexes = cls.index_management.batch_create_indexes(index_requests)


Expand Down
Loading