キャサンドラとセロリを一緒に持ってきません

Question

セロリとキャサンドラを一緒に使う例を試しています： http://datastax.github.io/python-driver/cqlengine/third_party.html 運がありません。

私は、この例外は、私は労働者を始めてもらう：INFO

[2016-06-12 14:11:53,609: ERROR/Worker-1] Process Worker-1 
Traceback (most recent call last): 
File "/Users/lutz/work/truncated/truncated-worker/venv/lib/python3.5/site-packages/billiard/process.py", line 292, in _bootstrap 
self.run() 
File "/Users/lutz/work/truncated/truncated-worker/venv/lib/python3.5/site-packages/billiard/pool.py", line 292, in run 
self.after_fork() 
File "/Users/lutz/work/truncated/truncated-worker/venv/lib/python3.5/site-packages/billiard/pool.py", line 395, in after_fork 
self.initializer(*self.initargs) 
File "/Users/lutz/work/truncated/truncated-worker/venv/lib/python3.5/site-packages/celery/concurrency/prefork.py", line 84, in process_initializer 
signals.worker_process_init.send(sender=None) 
File "/Users/lutz/work/truncated/truncated-worker/venv/lib/python3.5/site-packages/celery/utils/dispatch/signal.py", line 166, in send 
response = receiver(signal=self, sender=sender, **named) 
TypeError: cassandra_init() got an unexpected keyword argument 'sender' 

-l $セロリ-Aタスクワーカー私はOSXエルキャピタン、パイソン3.5.1、セロリ3.1を使用しています。 23およびカサンドラ3.5。

どのようなヘルプも歓迎されます。

Answer 1

cassandra_initシグナルハンドラ関数は任意のキーワード引数を受け入れる必要があります。 http://docs.celeryproject.org/en/latest/userguide/signals.html#basics

注：で、ユーザーガイドを参照してください、セロリ信号の詳細については

def cassandra_init(**kwargs): 

：

def cassandra_init(): 

へ：

だけの行を変更しそれが参考になりますあなたがそのチュートリアルの作者に何らかのレポートを提出した場合は、セロリのシグナルハンドラは常にキーワードの引数を必要としていますので、そこでは動作しないサンプルを持つのは悲しいことです。