from celery import shared_task @shared_task def process_dir(path): return path