Skip to content

Commit 60f7665

Browse files
removed force_parallel mode
1 parent 500a723 commit 60f7665

File tree

2 files changed

+0
-4
lines changed

2 files changed

+0
-4
lines changed

engine/clients/pgvector/config.py

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,6 @@
1010
PGVECTOR_PARALLEL_TUPLE_COST = float(os.getenv("PGVECTOR_PARALLEL_TUPLE_COST", 0.01))
1111
PGVECTOR_PARALLEL_SETUP_COST = int(os.getenv("PGVECTOR_PARALLEL_SETUP_COST", 100))
1212
PGVECTOR_MIN_PARALLEL_TABLE_SCAN_SIZE = os.getenv("PGVECTOR_MIN_PARALLEL_TABLE_SCAN_SIZE", "1MB")
13-
PGVECTOR_FORCE_PARALLEL_MODE = os.getenv("PGVECTOR_FORCE_PARALLEL_MODE", "on")
1413
PGVECTOR_WORK_MEM = os.getenv("PGVECTOR_WORK_MEM", "4GB")
1514

1615

engine/clients/pgvector/search.py

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,6 @@
1313
PGVECTOR_PARALLEL_TUPLE_COST,
1414
PGVECTOR_PARALLEL_SETUP_COST,
1515
PGVECTOR_MIN_PARALLEL_TABLE_SCAN_SIZE,
16-
PGVECTOR_FORCE_PARALLEL_MODE,
1716
PGVECTOR_WORK_MEM,
1817
)
1918
from engine.clients.pgvector.parser import PgVectorConditionParser
@@ -47,14 +46,12 @@ def init_client(cls, host, distance, connection_params: dict, search_params: dic
4746
parallel_tuple_cost = cls.search_params.get("parallel_tuple_cost", PGVECTOR_PARALLEL_TUPLE_COST)
4847
parallel_setup_cost = cls.search_params.get("parallel_setup_cost", PGVECTOR_PARALLEL_SETUP_COST)
4948
min_parallel_size = cls.search_params.get("min_parallel_table_scan_size", PGVECTOR_MIN_PARALLEL_TABLE_SCAN_SIZE)
50-
force_parallel = cls.search_params.get("force_parallel_mode", PGVECTOR_FORCE_PARALLEL_MODE)
5149
work_mem = cls.search_params.get("work_mem", PGVECTOR_WORK_MEM)
5250

5351
cls.cur.execute(f"SET max_parallel_workers_per_gather = {parallel_workers}")
5452
cls.cur.execute(f"SET parallel_tuple_cost = {parallel_tuple_cost}")
5553
cls.cur.execute(f"SET parallel_setup_cost = {parallel_setup_cost}")
5654
cls.cur.execute(f"SET min_parallel_table_scan_size = '{min_parallel_size}'")
57-
cls.cur.execute(f"SET force_parallel_mode = {force_parallel}")
5855
cls.cur.execute(f"SET work_mem = '{work_mem}'")
5956

6057
@classmethod

0 commit comments

Comments
 (0)