tune down concurrency

graphsense · Dec 19, 2023 · 764ef0d · 764ef0d
1 parent 73ec797
commit 764ef0d
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/graphsenselib/ingest/account.py b/src/graphsenselib/ingest/account.py
@@ -1352,7 +1352,7 @@ def submit_tasks(ex, thrd_ctx, tasks, data=None):
                     completed = next(concurrent.futures.as_completed(tasks))
                     tasks.remove(completed)
                     for cont_task, data in completed.result():
-                        # Get the data for the progess indicator
+                        # Get the data for the progress indicator
                         if isinstance(cont_task, StoreTask) and data[0] == "block":
                             blocks = data[1]
 

diff --git a/src/graphsenselib/ingest/common.py b/src/graphsenselib/ingest/common.py
@@ -6,7 +6,7 @@
 
 INGEST_SINKS = ["parquet", "cassandra"]
 
-CASSANDRA_INGEST_DEFAULT_CONCURRENCY = 1000
+CASSANDRA_INGEST_DEFAULT_CONCURRENCY = 100
 
 logger = logging.getLogger(__name__)