8000 [CHORE] reduce max concurrent reads on sync job in staging (#56) · chroma-core/package-search@353c0da · GitHub
[go: up one dir, main page]

Skip to content

Commit 353c0da

Browse files
authored
[CHORE] reduce max concurrent reads on sync job in staging (#56)
1 parent d41f516 commit 353c0da

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

.github/scripts/sync/main.py

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@
2525
"terraform",
2626
"ruby_gems",
2727
]
28-
MAX_CONCURRENT_CHROMA_READS = 10
28+
2929
MAX_CONCURRENT_DASHBOARD_BACKEND_WRITES = 50
3030
MAX_RETRIES_MARK_PUBLIC = 3
3131
BASE_RETRY_DELAY = 1.0
@@ -287,6 +287,8 @@ def main():
287287

288288
logger.success("Successfully accessed required environment variables")
289289

290+
max_concurrent_chroma_reads = 5 if "devchroma" in chroma_api_url else 10
291+
290292
# Initialize chroma clients for all databases
291293
logger.subsection("Initializing Clients")
292294
logger.info("Initializing chroma clients for all databases")
@@ -312,7 +314,7 @@ def main():
312314
list_errors = []
313315

314316
with concurrent.futures.ThreadPoolExecutor(
315-
max_workers=MAX_CONCURRENT_CHROMA_READS
317+
max_workers=max_concurrent_chroma_reads
316318
) as executor:
317319
# Submit list_collections tasks for all databases
318320
future_to_db = {

0 commit comments

Comments
 (0)
0