We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 7be9842 commit 8d3bfceCopy full SHA for 8d3bfce
airbyte_cdk/sources/declarative/incremental/concurrent_partition_cursor.py
@@ -58,7 +58,7 @@ class ConcurrentPerPartitionCursor(Cursor):
58
CurrentPerPartitionCursor expects the state of the ConcurrentCursor to follow the format {cursor_field: cursor_value}.
59
"""
60
61
- DEFAULT_MAX_PARTITIONS_NUMBER = 10000
+ DEFAULT_MAX_PARTITIONS_NUMBER = 1000
62
_NO_STATE: Mapping[str, Any] = {}
63
_NO_CURSOR_STATE: Mapping[str, Any] = {}
64
_GLOBAL_STATE_KEY = "state"
0 commit comments