Skip to content

Commit 4fac2b2

Browse files
authored
chore: tweak the default value of source_max_inflight_rows (#853)
1 parent 97b49e9 commit 4fac2b2

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

docs/docs/core/settings.mdx

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -118,7 +118,7 @@ If you use the Postgres database hosted by [Supabase](https://supabase.com/), pl
118118

119119
`GlobalExecutionOptions` is used to configure the global execution options shared by all flows. It has the following fields:
120120

121-
* `source_max_inflight_rows` (type: `int | None`, default: `256`): The maximum number of concurrent inflight rows for all source operations.
121+
* `source_max_inflight_rows` (type: `int | None`, default: `1024`): The maximum number of concurrent inflight rows for all source operations.
122122
* `source_max_inflight_bytes` (type: `int | None`, default: `None`): The maximum number of concurrent inflight bytes for all source operations.
123123

124124
See also [flow definition docs](/docs/core/flow_def#control-processing-concurrency) about why it's necessary to control processing concurrency, and how to configure it on per-source basis.
@@ -136,5 +136,5 @@ This is the list of environment variables, each of which has a corresponding fie
136136
| `COCOINDEX_DATABASE_PASSWORD` | `database.password` | No |
137137
| `COCOINDEX_DATABASE_MAX_CONNECTIONS` | `database.max_connections` | No (default: `64`) |
138138
| `COCOINDEX_DATABASE_MIN_CONNECTIONS` | `database.min_connections` | No (default: `16`) |
139-
| `COCOINDEX_SOURCE_MAX_INFLIGHT_ROWS` | `global_execution_options.source_max_inflight_rows` | No (default: `256`) |
139+
| `COCOINDEX_SOURCE_MAX_INFLIGHT_ROWS` | `global_execution_options.source_max_inflight_rows` | No (default: `1024`) |
140140
| `COCOINDEX_SOURCE_MAX_INFLIGHT_BYTES` | `global_execution_options.source_max_inflight_bytes` | No |

python/cocoindex/setting.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -53,7 +53,7 @@ class GlobalExecutionOptions:
5353
"""Global execution options."""
5454

5555
# The maximum number of concurrent inflight requests, shared among all sources from all flows.
56-
source_max_inflight_rows: int | None = 256
56+
source_max_inflight_rows: int | None = 1024
5757
source_max_inflight_bytes: int | None = None
5858

5959

0 commit comments

Comments
 (0)