create_user(username, password): User.objects.create(username=username, password=password) 2.2.2 Context task.request contains information and state related the currently executing task, and must always contain the @task def add(x, y): print("Executing task id %r, args: %r kwargs: %r" % ( add.request.id, add.request.args, add.request.kwargs)) 16 Chapter 2. User Guide Celery Documentation, Release 2.3.5 2.2.3 Logging task is mandatory, an exception will be raised instead. Not supported by amqplib. Task.immediate Request immediate delivery. If the task cannot be routed to a task worker immediately, an exception will

create_user(username, password): User.objects.create(username=username, password=password) Context task.request contains information and state related the currently executing task, and must always contain the add(x, y): print("Executing task id %r, args: %r kwargs: %r" % ( add.request.id, add.request.args, add.request.kwargs)) Logging You can use the workers logger to add diagnostic output to the task is mandatory, an exception will be raised instead. Not supported by amqplib. Task.immediate Request immediate delivery. If the task cannot be routed to a task worker immediately, an exception will

create_user(username, password): User.objects.create(username=username, password=password) Context task.request contains information and state related the currently executing task, and must always contain the add(x, y): print("Executing task id %r, args: %r kwargs: %r" % ( add.request.id, add.request.args, add.request.kwargs)) Logging You can use the workers logger to add diagnostic output to the task is mandatory, an exception will be raised instead. Not supported by amqplib. Task.immediate Request immediate delivery. If the task cannot be routed to a task worker immediately, an exception will

create_user(username, password): User.objects.create(username=username, password=password) 2.2.2 Context task.request contains information and state related the currently executing task, and must always contain the @task def add(x, y): print("Executing task id %r, args: %r kwargs: %r" % ( add.request.id, add.request.args, add.request.kwargs)) 2.2.3 Logging You can use the workers logger to add diagnostic output task is mandatory, an exception will be raised instead. Not supported by amqplib. Task.immediate Request immediate delivery. If the task cannot be routed to a task worker immediately, an exception will

create_user(username, password): User.objects.create(username=username, password=password) Context task.request contains information and state related the currently executing task, and must always contain the add(x, y): print("Executing task id %r, args: %r kwargs: %r" % ( add.request.id, add.request.args, add.request.kwargs)) Logging You can use the workers logger to add diagnostic output to the task is mandatory, an exception will be raised instead. Not supported by amqplib. Task.immediate Request immediate delivery. If the task cannot be routed to a task worker immediately, an exception will

create_user(username, password): User.objects.create(username=username, password=password) 2.2.2 Context task.request contains information and state related the currently executing task, and must always contain the @task def add(x, y): print("Executing task id %r, args: %r kwargs: %r" % ( add.request.id, add.request.args, add.request.kwargs)) 2.2.3 Logging You can use the workers logger to add diagnostic output task is mandatory, an exception will be raised instead. Not supported by amqplib. Task.immediate Request immediate delivery. If the task cannot be routed to a task worker immediately, an exception will

received by every worker in the cluster. You can also specify one or more workers to act on the request using the -- destination option. This is a comma-separated list of worker host names: $ celery -A --destination=celery@example.com If a destination isn’t provided then every worker will act and reply to the request. The celery inspect command contains commands that don’t change anything in the worker; it only DebugTask(Task): def __call__(self, *args, **kwargs): print('TASK STARTING: {0.name}[{0.request.id}]'.format(self)) return self.run(*args, **kwargs) Tip If you override the task’s __call__

received by every worker in the cluster. You can also specify one or more workers to act on the request using the -- destination option. This is a comma-separated list of worker host names: $ celery -A --destination=celery@example.com If a destination isn’t provided then every worker will act and reply to the request. The celery inspect command contains commands that don’t change anything in the worker; it only DebugTask(Task): def __call__(self, *args, **kwargs): print('TASK STARTING: {0.name}[{0.request.id}]'.format(self)) return self.run(*args, **kwargs) Tip If you override the task’s __call__

received by every worker in the cluster. You can also specify one or more workers to act on the request using the -- destination option. This is a comma-separated list of worker host names: $ celery -A --destination=celery@example.com If a destination isn’t provided then every worker will act and reply to the request. The celery inspect command contains commands that don’t change anything in the worker; it only DebugTask(Task): def __call__(self, *args, **kwargs): print('TASK STARTING: {0.name}[{0.request.id}]'.format(self)) return self.run(*args, **kwargs) Tip If you override the task’s __call__

received by every worker in the cluster. You can also specify one or more workers to act on the request using the -- destination option. This is a comma-separated list of worker host names: $ celery -A --destination=celery@example.com If a destination isn’t provided then every worker will act and reply to the request. The celery inspect command contains commands that don’t change anything in the worker; it only DebugTask(Task): def __call__(self, *args, **kwargs): print('TASK STARTING: {0.name}[{0.request.id}]'.format(self)) return self.run(*args, **kwargs) Tip If you override the task’s __call__