| # app/workers/tasks.py | |
| import redis | |
| import json | |
| import uuid | |
| import os | |
| r = redis.Redis( | |
| host=os.getenv("REDIS_HOST", "localhost"), | |
| port=int(os.getenv("REDIS_PORT", 6379)), | |
| password=os.getenv("REDIS_PASSWORD", None), | |
| decode_responses=True | |
| ) | |
| def enqueue_task(task: dict): | |
| task_id = str(uuid.uuid4()) | |
| task["task_id"] = task_id | |
| r.lpush("tasks", json.dumps(task)) | |
| return task_id |