Create API endpoint to schedule the ping-farms task. Closes farmOS#45

paul121 · Nov 25, 2019 · 976aad9 · 976aad9
1 parent 3fdc07a
commit 976aad9
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/backend/app/app/api/api_v1/endpoints/utils.py b/backend/app/app/api/api_v1/endpoints/utils.py
@@ -20,15 +20,15 @@
 router = APIRouter()
 
 
-@router.post("/test-celery/", response_model=Msg, status_code=201)
-def test_celery(
-    msg: Msg, current_user: UserInDB = Depends(get_current_active_superuser)
+@router.post("/ping-farms/", response_model=Msg, status_code=201)
+def ping_farms(
+    current_user: UserInDB = Depends(get_current_active_superuser)
 ):
     """
-    Test Celery worker.
+    Ping all farms.
     """
-    celery_app.send_task("app.worker.test_celery", args=[msg.msg])
-    return {"msg": "Word received"}
+    celery_app.send_task("app.worker.ping_farms")
+    return {"msg": "Task created. Check farm last_updated values."}
 
 
 @router.post("/test-email/", response_model=Msg, status_code=201)