-
Notifications
You must be signed in to change notification settings - Fork 192
Open
Labels
bugSomething isn't workingSomething isn't working
Description
What language are you using?
Python 3.12
What version are you using?
0.4.3
What database are you using?
MySQL
What dataframe are you using?
Pandas
Can you describe your bug?
In each process I run cx.read_sql() per 5 seconds. Some process will hangs up after running for a period of time. Sometimes this will take 20 minutes, and sometimes hours.
What are the steps to reproduce the behavior?
Here is my code:
processes = []
p = multiprocessing.Process(target =
run_table1_query, name =
"run_query_1")
processes.append(p)
p.start()
p = multiprocessing.Process(target =
run_table1_query, name =
"run_query_2")
processes.append(p)
p.start()
p = multiprocessing.Process(target =
run_table1_query, name =
"run_query_3")
processes.append(p)
p.start()
p = multiprocessing.Process(target =
run_table2_query, name = "table2_query_1")
processes.append(p)
p.start()
p = multiprocessing.Process(target =
run_table2_query, name = "table2_query_2")
processes.append(p)
p.start()
p = multiprocessing.Process(target =
run_table2_query, name = "table2_query_3")
processes.append(p)
p.start()
for p in processes:
p.join()
run_table2_query
and run_table1_query
is the function in which I call cx.read_sql() per 5 seconds.
Database setup if the error only happens on specific data or data type
Table schema and example data
Example query / code
SELECT * FROM my_table where mddate = 20250501
What is the error?
No error occouring, but I got these logs if I set os.environ['RUST_LOG'] = "connectorx=debug,connectorx_python=debug" :
It seems that each time it will hang in different code position.
Metadata
Metadata
Assignees
Labels
bugSomething isn't workingSomething isn't working