python 3.x - Celery handling named argument -


i have celery task this

@app.task(bind=true,max_retries=3, default_retry_delay=1 * 60)   def dotargetprefilter(self,*args,**kwargs ):

i calling as

args = [none,sourcedns, targetdnlist] kwargs= {'workername':workername,} result = r.dotargetprefilter.apply_async(*args,**kwargs)

however getting strange error

file "/usr/local/lib/python3.4/dist-packages/celery/app/amqp.py", line 254, in publish_task raise valueerror('task kwargs must dictionary')

valueerror: task kwargs must dictionary

a small unit test of invocation works fine; 

def test_dotargetprefilter(self):      ltecpxx.mrosimpleexecutor import dotargetprefilter     s=[1,2,3]     t=[1,2,2]     workername="ltecpxx.mrosimpleexecutor.simpleprefilter"     args =[none,s,t]     kwargs={'wokername':workername}     dotargetprefilter(*args,**kwargs)

i have tried sorts of combinaiton , seen apply_async documentation. works if make normal method (without *args , **kwargs); doing wrong

the bind annotation supplies self; need remove args list, , arguments must in tuple when call apply_async. changing these 2 give

args = [sourcedns, targetdnlist] kwargs= {'workername':workername} result = r.dotargetprefilter.apply_async((args),kwargs)

and function signature

@app.task(bind=true,max_retries=3, default_retry_delay=1 * 60)  # retry in 1 minutes. def dotargetprefilter(self,*args,workername=""):

Comments

Post a Comment

Popular posts from this blog

user interface - how to replace an ongoing process of image capture from another process call over the same ImageLabel in python's GUI TKinter -

i trying use following code create interactive gui changes color-space(hsv, rbg, grayscale etc) on event of button click. display opencv video in tkinter using multiprocessing being new python having problems multiprocessing , attempts on making gui change it's color space on button clicks hangs entire system. on it's implementation highly appreciated. thankyou. below code: import cv2 pil import image,imagetk import tkinter tk import numpy np multiprocessing import process , queue def quit_it(root,process): root.destroy() process.terminate() def black_andwhite(root,process): process.terminate p=process(target=capture_image, args=(5,queue, )) p.start() root.after(0, func=lambda: update_all(root, image_label, queue)) def update_image(image_label, queue): frame = queue.get() = image.fromarray(frame) b = imagetk.photoimage(image=a) image_label.configure(image=b) image_label._image_cache = b root.update() def update_all(root...
Read more

javascript - Restarting Supervisor and effect on FlaskSocketIO -

in index.html (html/javascript) have: $(document).ready(function(){ namespace = '/test'; var socket = io.connect('http://' + document.domain + ':' + location.port + namespace); socket.on('connect', function() { socket.emit('join', {room: 'venue_1'}); }); socket.on('my response', function(msg) { $('#log').append('<br>received #' + ': ' + msg.data); }); }); on server have: @socketio.on('connect', namespace='/test') def test_connect(): if session.get('venue_id'): emit('my response', {'data': 'connected'}) session.pop('venue_id', none) else: request.namespace.disconnect() @socketio.on('join', namespace='/test') def join(message): join_room(message['room']) room = message[...
Read more

android - Format a french phone number -

i have format "0612345678" "06 12 34 56 78". i'm using : private string formattel(string number) { try { string formattednumber = ""; int i; (i = 0; < 10; += 2) { formattednumber += number.substring(i, + 2) + " "; } return formattednumber.substring(0, formattednumber.length() - 1); } catch (indexoutofboundsexception e) { return number; } } it works on emulator running api 16 (jellybean 4.1.1) : on it, result looks want ("06 12 34 56 78") on own phone, (api 22, lollipop 5.1.1), doesn't work : result "0 61 23 45 67" whereas method same ! i did research , i've found string.format method. it's here need help, it's hard me... ! thank in advance :d edit : working method, using libphonenumber : private string formattel(string number) { string formattednumber = number; try { phonenumberutil phonenumberutil = ph...
Read more