Сельдерей — «WorkerLostError: работник вышел преждевременно: сигнал 11 (SIGSEGV)» ⇐ Python

[Anonymous]

Я работаю над приложением Django локально, которое должно принимать CSV-файл в качестве входных данных и выполнять некоторый анализ этого файла. Я использую Celery, RabbitMQ и веб-сервер локально. Когда я импортирую файл, я вижу следующую ошибку на сервере Celery:

[2015-12-11 16:58:53,906: WARNING/MainProcess] celery@Joes-MBP ready.
[2015-12-11 16:59:11,068: ERROR/MainProcess] Task program_manager.tasks.analyze_list_import_program[db22de16-b92f-4220-b2bd-5accf484c99a] raised unexpected: WorkerLostError('Worker exited prematurely: signal 11 (SIGSEGV).',)
Traceback (most recent call last):
File "/Users/joefusaro/rl_proto2/venv/lib/python2.7/site-packages/billiard/pool.py", line 1175, in mark_as_worker_lost
human_status(exitcode)),
WorkerLostError: Worker exited prematurely: signal 11 (SIGSEGV).


Я не знаю, как устранить эту неполадку дальше; если это поможет, я скопировал соответствующий код из program_manager/tasks.py:

from __future__ import absolute_import

import csv
import rollbar
from celery import shared_task
from celery.utils.log import get_task_logger

from qscore.models import QualityScore
from integrations.salesforce.prepare import read_csv
from qscore.quality_score import QualityScoreCalculator

logger = get_task_logger(__name__)

@shared_task
def analyze_list_import_program(program):
program.status = 'RUN'
program.save()

df = read_csv(program.csv_file.file)
try:
qs = program.get_current_quality_score()
qs_calc = QualityScoreCalculator(df, qs)
qscore_data = qs_calc.calculate()
QualityScore.objects.filter(id=qs.id).update(**qscore_data)
except Exception as e:
rollbar.report_exc_info()
program.status = 'ERROR'
else:
program.status = 'COMPL'
finally:
program.save()


Подробнее здесь: https://stackoverflow.com/questions/342 ... 11-sigsegv