def add(x, y): return x + y Handlers execute(self, request, pool, loglevel, logfile, **kw): Parameters • request – A TaskRequest. • pool – The task pool. • loglevel – Current loglevel. • logfile after_return(self, status, retval, task_id, args, kwargs, einfo) Handler called after the task returns. Parameters • status – Current task state. • retval – Task return value/exception. • task_id – Unique id on_failure(self, exc, task_id, args, kwargs, einfo) This is run by the worker when the task fails. Parameters • exc – The exception raised by the task. • task_id – Unique id of the failed task. • args –

def add(x, y): return x + y Handlers execute(self, request, pool, loglevel, logfile, **kw): Parameters • request – A TaskRequest. • pool – The task pool. • loglevel – Current loglevel. • logfile after_return(self, status, retval, task_id, args, kwargs, einfo) Handler called after the task returns. Parameters • status – Current task state. • retval – Task return value/exception. • task_id – Unique id on_failure(self, exc, task_id, args, kwargs, einfo) This is run by the worker when the task fails. Parameters • exc – The exception raised by the task. • task_id – Unique id of the failed task. • args –

add(x, y): return x + y Handlers execute(self, request, pool, loglevel, logfile, **kw): Parameters: request – A TaskRequest. pool – The task pool. loglevel – Current loglevel. logfile – Name of after_return(self, status, retval, task_id, args, kwargs, einfo) Handler called after the task returns. Parameters: status – Current task state. retval – Task return value/exception. task_id – Unique id of the on_failure(self, exc, task_id, args, kwargs, einfo) This is run by the worker when the task fails. Parameters: exc – The exception raised by the task. task_id – Unique id of the failed task. args – Original

declare(exchange_name, type, passive, durable, auto_delete, internal) Declares an exchange by name. Parameters • passive – Passive means the exchange won’t be created, but you can use this to check if the log=None, control=None, set_as_current=True, accept_magic_kwargs=False) Celery Application. Parameters • main – Name of the main module if running as __main__. • loader – The loader class, or the connect_timeout=None, result_cls=None, expires=None, queues=None, **options) Send task by name. Parameters • name – Name of task to execute (e.g. “tasks.add”). • result_cls – Specify custom result class

declare(exchange_name, type, passive, durable, auto_delete, internal) Declares an exchange by name. Parameters • passive – Passive means the exchange won’t be created, but you can use this to check if the a datetime. classmethod AsyncResult(task_id) Get AsyncResult instance for this kind of task. Parameters task_id – Task id to get result for. exception MaxRetriesExceededError The tasks max restart after_return(status, retval, task_id, args, kwargs, einfo=None) Handler called after the task returns. Parameters • status – Current task state. • retval – Task return value/exception. • task_id – Unique id

def add(x, y): return x + y Handlers execute(self, request, pool, loglevel, logfile, **kw): Parameters • request – A TaskRequest. • pool – The task pool. • loglevel – Current loglevel. • logfile after_return(self, status, retval, task_id, args, kwargs, einfo) Handler called after the task returns. Parameters • status – Current task state. • retval – Task return value/exception. • task_id – Unique id on_failure(self, exc, task_id, args, kwargs, einfo) This is run by the worker when the task fails. Parameters • exc – The exception raised by the task. • task_id – Unique id of the failed task. • args –

add(x, y): return x + y Handlers execute(self, request, pool, loglevel, logfile, **kw): Parameters: request – A TaskRequest. pool – The task pool. loglevel – Current loglevel. logfile – Name of after_return(self, status, retval, task_id, args, kwargs, einfo) Handler called after the task returns. Parameters: status – Current task state. retval – Task return value/exception. task_id – Unique id of the on_failure(self, exc, task_id, args, kwargs, einfo) This is run by the worker when the task fails. Parameters: exc – The exception raised by the task. task_id – Unique id of the failed task. args – Original

declare(exchange_name, type, passive, durable, auto_delete, internal) Declares an exchange by name. Parameters: passive – Passive means the exchange won’t be created, but you can use this to check if the exchange log=None, control=None, set_as_current=True, accept_magic_kwargs=False) Celery Application. Parameters: main – Name of the main module if running as __main__. loader – The loader class, or the name connect_timeout=None, result_cls=None, expires=None, queues=None, **options) Send task by name. Parameters: name – Name of task to execute (e.g. “tasks.add”). result_cls – Specify custom result class.

add(x, y): return x + y Handlers execute(self, request, pool, loglevel, logfile, **kw): Parameters: request – A TaskRequest. pool – The task pool. loglevel – Current loglevel. logfile – Name of after_return(self, status, retval, task_id, args, kwargs, einfo) Handler called after the task returns. Parameters: status – Current task state. retval – Task return value/exception. task_id – Unique id of the on_failure(self, exc, task_id, args, kwargs, einfo) This is run by the worker when the task fails. Parameters: exc – The exception raised by the task. task_id – Unique id of the failed task. args – Original

declare(exchange_name, type, passive, durable, auto_delete, internal) Declares an exchange by name. Parameters: passive – Passive means the exchange won’t be created, but you can use this to check if the exchange a datetime. classmethod AsyncResult(task_id) Get AsyncResult instance for this kind of task. Parameters: task_id – Task id to get result for. exception MaxRetriesExceededError The tasks max restart after_return(status, retval, task_id, args, kwargs, einfo=None) Handler called after the task returns. Parameters: status – Current task state. retval – Task return value/exception. task_id – Unique id of the