revert

Author: Sung Won Chung

data_diff/databases/mysql.py

@@ -1,4 +1,4 @@
-from typing import Any, ClassVar, Dict, Type, Union
+from typing import Any, ClassVar, Dict, Type
 
 import attrs
 
@@ -20,7 +20,6 @@
  import_helper,
  ConnectError,
  BaseDialect,
- ThreadLocalInterpreter,
 )
 from data_diff.databases.base import (
  MD5_HEXDIGITS,
@@ -149,14 +148,3 @@ def create_connection(self):
  elif e.errno == mysql.errorcode.ER_BAD_DB_ERROR:
  raise ConnectError("Database does not exist") from e
  raise ConnectError(*e.args) from e
-
- def _query_in_worker(self, sql_code: Union[str, ThreadLocalInterpreter]):
- "This method runs in a worker thread"
- if self._init_error:
- raise self._init_error
- if not self.thread_local.conn.is_connected():
- try:
- self.thread_local.conn.ping(reconnect=True, attempts=3, delay=5)
- except Exception as e:
- raise ConnectError(*e.args) from e
- return self._query_conn(self.thread_local.conn, sql_code)