diff --git a/src/graphsenselib/ingest/account.py b/src/graphsenselib/ingest/account.py index e8f9506..9fec407 100644 --- 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 index 067d367..01ec28a 100644 --- 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__)