不能把卡桑德拉和芹菜放在一起

Question

我想要一起使用芹菜和卡桑德拉的例子： http://datastax.github.io/python-driver/cqlengine/third_party.html 但沒有運氣。

我得到這個例外的我開始與工人： $芹菜-A任務工人-l 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' 

我使用OSX埃爾卡皮坦，蟒蛇3.5.1，芹菜3.1。 23和cassandra 3.5。

所以，任何幫助將受到歡迎。

Answer 1

您的cassandra_init信號處理函數需要接受任意的關鍵字參數。

簡單地改變行：

def cassandra_init(): 

到：

def cassandra_init(**kwargs): 

有關芹菜信號的詳細信息，請參閱用戶指南在： http://docs.celeryproject.org/en/latest/userguide/signals.html#basics

注：這將是有益的如果您還向該教程的作者提交了某種報告。 Celery信號處理程序總是需要關鍵字參數，所以在那裏有非工作示例是很可悲的。