from project.redmine.agregator import Redmine
@task(executor=TaskExecutor.SPOOLER, retry_count=1, retry_timeout=5)
def redmine_data_update():
    r = Redmine()
    r.import_tasks()

 import logging
log = logging.getLogger('tasks')
class Redmine:
    db = None
    def __init__(self):
        self.db = _mysql.connect(host=settings.REDMINE_DB_HOST, db=settings.REDMINE_DB_NAME,
                                 user=settings.REDMINE_DB_USER, passwd=settings.REDMINE_DB_PASS)
        self.db.query("SET NAMES utf8;")
        self.db.query("SET CHARACTER SET utf8;")
        self.db.query("SET character_set_connection=utf8;")
        log.info('MySQL connection to redmine opened.')
    def __del__(self):
        self.db.close()
        log.info('MySQL connection to redmine closed.')
    def import_tasks(self):
        query = "SELECT ... сам запрос"
        try:
            self.db.query(query)
            res = self.db.use_result()
            rs = list(RedmineTasks.objects.filter().values_list('task_id', flat=True))
        except Exception as e:
            log.error('MySQL error: %s' % e)
            return
        row = res.fetch_row()

 (tasks:24) MySQL connection to redmine opened.
(tasks:28) MySQL connection to redmine closed.

 (tasks:24) MySQL connection to redmine opened.
(tasks:48) MySQL error: (2006, 'MySQL server has gone away')