16 lines
245 B
Python
16 lines
245 B
Python
|
|
from celery import Celery
|
|
import os
|
|
|
|
redis_url = os.getenv("REDIS_URL", "redis://redis:6379/0")
|
|
|
|
celery_app = Celery(
|
|
"worker",
|
|
broker=redis_url,
|
|
backend=redis_url
|
|
)
|
|
|
|
@celery_app.task
|
|
def test_task():
|
|
return "Worker is running"
|