File tree Expand file tree Collapse file tree 1 file changed +7
-0
lines changed
clickhouse_connect/driver Expand file tree Collapse file tree 1 file changed +7
-0
lines changed Original file line number Diff line number Diff line change 11import asyncio
22import io
3+ import logging
34import os
45from concurrent .futures .thread import ThreadPoolExecutor
56from datetime import tzinfo
1415from clickhouse_connect .datatypes .base import ClickHouseType
1516from clickhouse_connect .driver .insert import InsertContext
1617
18+ logger = logging .getLogger (__name__ )
19+
20+
1721class DefaultThreadPoolExecutor :
1822 pass
1923
@@ -43,6 +47,9 @@ def __init__(self,
4347 self .new_executor = True
4448 self .executor = ThreadPoolExecutor (max_workers = executor_threads )
4549 else :
50+ if executor_threads != 0 :
51+ logger .warning ('executor_threads parameter is ignored when passing an executor object' )
52+
4653 self .new_executor = False
4754 self .executor = executor
4855
You can’t perform that action at this time.
0 commit comments