@shared_task
def fanout_operation(feed_manager, feed_class, user_ids, operation, operation_kwargs):
 feed_manager.fanout(user_ids, feed_class, operation, operation_kwargs)
 return ('%d user_ids, %r, %r (%r)' % (len(user_ids), feed_class, operation, operation_kwargs))

@ shared_task def fanout_operation ( feed_manager , feed_class , user_ids , operation , operation_kwargs ) : feed_manager . fanout ( user_ids , feed_class , operation , operation_kwargs ) return ( '%d user_ids, %r, %r (%r)' % ( len ( user_ids ) , feed_class , operation , operation_kwargs ) )
simple task wrapper for _fanout task just making sure code is where you expect it :) .