1from celery import Celery 2 3celery = Celery( 4 "worker", 5 broker="redis://redis:6379/0" 6) 7 8@celery.task 9def process_document(document_path): 10 11 print(f"Processing: {document_path}") 12 13 return { 14 "status": "completed" 15 }