File tree Expand file tree Collapse file tree 1 file changed +4
-2
lines changed Expand file tree Collapse file tree 1 file changed +4
-2
lines changed Original file line number Diff line number Diff line change 25
25
"terraform" ,
26
26
"ruby_gems" ,
27
27
]
28
- MAX_CONCURRENT_CHROMA_READS = 10
28
+
29
29
MAX_CONCURRENT_DASHBOARD_BACKEND_WRITES = 50
30
30
MAX_RETRIES_MARK_PUBLIC = 3
31
31
BASE_RETRY_DELAY = 1.0
@@ -287,6 +287,8 @@ def main():
287
287
288
288
logger .success ("Successfully accessed required environment variables" )
289
289
290
+ max_concurrent_chroma_reads = 5 if "devchroma" in chroma_api_url else 10
291
+
290
292
# Initialize chroma clients for all databases
291
293
logger .subsection ("Initializing Clients" )
292
294
logger .info ("Initializing chroma clients for all databases" )
@@ -312,7 +314,7 @@ def main():
312
314
list_errors = []
313
315
314
316
with concurrent .futures .ThreadPoolExecutor (
315
- max_workers = MAX_CONCURRENT_CHROMA_READS
317
+ max_workers = max_concurrent_chroma_reads
316
318
) as executor :
317
319
# Submit list_collections tasks for all databases
318
320
future_to_db = {
You can’t perform that action at this time.
0 commit comments