File size: 409 Bytes
f5827ac | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 | # 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 |