Skip to content

Commit 9dd093b

Browse files
committed
Increased timeouts for CH client
1 parent 05b6028 commit 9dd093b

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

mysql_ch_replicator/clickhouse_api.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -32,6 +32,8 @@
3232
class ClickhouseApi:
3333
MAX_RETRIES = 5
3434
RETRY_INTERVAL = 30
35+
CONNECT_TIMEOUT = 30
36+
SEND_RECEIVE_TIMEOUT = 120
3537

3638
def __init__(self, database: str, clickhouse_settings: ClickhouseSettings):
3739
self.database = database
@@ -41,6 +43,8 @@ def __init__(self, database: str, clickhouse_settings: ClickhouseSettings):
4143
port=clickhouse_settings.port,
4244
username=clickhouse_settings.user,
4345
password=clickhouse_settings.password,
46+
connect_timeout=ClickhouseApi.CONNECT_TIMEOUT,
47+
send_receive_timeout=ClickhouseApi.SEND_RECEIVE_TIMEOUT,
4448
)
4549
self.tables_last_record_version = {} # table_name => last used row version
4650
self.execute_command('SET final = 1;')

0 commit comments

Comments
 (0)