python
from celery import Celery
app = Celery('distributed_tasks')
app.conf.task_default_queue = 'distributed_tasks'
app.autodiscover_tasks(['tasks'])
python
from celery import shared_task
@shared_task
def process_task(data):
result = process_data(data)
return result
def process_data(data):
return processed_data
bash
celery -A celery worker --loglevel=info
python
from tasks import process_task
result = process_task.delay(data)
if result.ready():
task_result = result.get()
print(task_result)
