Kann Cassandra und Sellerie nicht zusammen bringen

Question

Ich versuche das Beispiel, Sellerie und Cassandra zusammen zu verwenden: http://datastax.github.io/python-driver/cqlengine/third_party.html Aber ohne Glück.

Ich erhalte diese Ausnahme die ich beginne den Arbeiter mit: $ Sellerie -A Aufgaben Arbeiter -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' 

Ich verwende osx el Capitan, Python 3.5.1, Sellerie 3.1. 23 und Cassandra 3.5.

So jede Hilfe wird willkommen sein.

Answer 1

Ihre Signalverarbeitungsfunktion cassandra_init muss beliebige Schlüsselwortargumente akzeptieren.

einfach die Zeile:

def cassandra_init(): 

in:

def cassandra_init(**kwargs): 

Weitere Informationen über Sellerie Signale finden Sie in der Bedienungsanleitung unter: http://docs.celeryproject.org/en/latest/userguide/signals.html#basics

Hinweis: Es wäre hilfreich, wenn Sie dem Autor dieses Tutorials auch eine Art Bericht vorgelegt haben. Sellerie Signalhandler haben immer die Schlüsselwortargumente benötigt, so dass es traurig ist, nicht funktionierende Beispiele da draußen zu haben.