FIX: update celery and fix revoke method

D10S0VSkY-OSS · Jan 10, 2022 · c06dae7 · c06dae7
1 parent ba6e58a
commit c06dae7
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/.github/workflows/sld-api-docker-image.yml b/.github/workflows/sld-api-docker-image.yml
@@ -26,10 +26,10 @@ jobs:
 
     - name: Build the Docker image with tag
       working-directory: ./sld-api-backend
-      run: docker build . --file Dockerfile --tag ${{ secrets.DOCKER_USERNAME }}/sld-api:2.1.1
+      run: docker build . --file Dockerfile --tag ${{ secrets.DOCKER_USERNAME }}/sld-api:2.1.2
 
     - name: Docker Push with tag
-      run: docker push ${{ secrets.DOCKER_USERNAME }}/sld-api:2.1.1
+      run: docker push ${{ secrets.DOCKER_USERNAME }}/sld-api:2.1.2
 
     - name: Build the Docker image
       working-directory: ./sld-api-backend

diff --git a/sld-api-backend/api_v1/endpoints/tasks.py b/sld-api-backend/api_v1/endpoints/tasks.py
@@ -2,7 +2,7 @@
 from sqlalchemy.orm import Session
 from fastapi import APIRouter, Depends, HTTPException
 from celery.result import AsyncResult
-from celery.task.control import revoke
+from config.celery_config import celery_app 
 
 from schemas import schemas
 from security import deps
@@ -25,7 +25,7 @@
 async def get_task_by_id(
         task_id: str,
         current_user: schemas.User = Depends(deps.get_current_active_user)):
-    result = revoke(task_id, terminate=True)
+    result = celery_app.control.revoke(task_id, terminate=True)
     return {"result": f'REVOKE {task_id}'}