mysql при использовании concurrent.futures

Мой код выглядит следующим образом.

for i in self.parent_job.child_jobs: futures.append(executor.submit(invokeRunCommand, i)) for future in concurrent.futures.as_completed(futures): print("Future Exception: %s" %future.exception()) executor.shutdown(wait="True") def invokeRunCommand(self): db_connect, db_cur = connect_to_database_pl() self.setJobStatus(db_cur, JOB_RUNNING) ... def setJobStatus(self, db_cur, job_status, run_status=RUN_PASSED): self.job_status = job_status sql = """UPDATE jobs SET job_status=%d WHERE job_id=%d""" \ %(job_status, self.job_id) db_cur.execute(sql) def connect_to_database_pl(dict_cursor=1): database = SQL_DB db_users = { 'employee' : {'user' : 'test', 'password' : 'test123'}, } user = db_users[database]['user'] password = db_users[database]['password'] try: db_cnxn = MySQLdb.connect (host = SQL_HOST, user = user, passwd = password, db = database) if dict_cursor==0: db_curs = db_cnxn.cursor() else: db_curs = db_cnxn.cursor(MySQLdb.cursors.DictCursor) except MySQLdb.Error, e: print "Error %d: %s" % (e.args[0], e.args[1]) sys.exit (1) return (db_cnxn, db_curs) 

Я сталкиваюсь с ошибками «Ошибка 2013: Потерянное соединение с сервером MySQL во время запроса. Будущее исключение: 1 ошибка сегментации» и «Ошибка 2006: сервер MySQL ушел. Будущее исключение: 1»

Хотя я создаю объект подключения в будущем, я получаю вышеуказанные ошибки.

Может ли кто-нибудь помочь мне избавиться от этой ошибки?

 
Interesting Posts for Van-Lav

Traceback при обновлении статуса на твиттере через Tweepy

Создать или добавить к списку в словаре – можно ли это сократить?

Pandas: замена значений столбцов в dataframe

отслеживание утечек памяти в Python (многопроцессорная обработка)

Производительность: асинхронный обработчик запросов с задачами блокировки, выполняемыми пулом работников

Поиск пересечения кривой из полифита

Использование RegEx для соответствия IP-адресам в Python

Как сравнить функции python с точки зрения производительности?

Как я могу «разделить» на два значения?

Сохранение матрицы matplotlib / networkx без полей

как я могу избежать сохранения команды в истории ipython?

как преобразовать волновой файл в амплитуду поплавка

Не удается поймать издеваемое исключение, поскольку оно не наследует BaseException

Самый простой пример для потоковой передачи аудио с Alexa

Проблема чтения двоичных файлов Python

Python - лучший язык программирования в мире.