Merge pull request #994 from xucailiang/fix-celery-import-error

rename celery.py

application/api/user/routes.py

@@ -229,7 +229,7 @@ def upload_remote():
 def task_status():
     """Get celery job status."""
     task_id = request.args.get("task_id")
-    from application.celery import celery
+    from application.celery_init import celery
 
     task = celery.AsyncResult(task_id)
     task_meta = task.info

application/api/user/tasks.py

@@ -1,5 +1,5 @@
 from application.worker import ingest_worker, remote_worker
-from application.celery import celery
+from application.celery_init import celery
 
 @celery.task(bind=True)
 def ingest(self, directory, formats, name_job, filename, user):

application/app.py

@@ -1,6 +1,6 @@
 import platform
 import dotenv
-from application.celery import celery
+from application.celery_init import celery
 from flask import Flask, request, redirect
 from application.core.settings import settings
 from application.api.user.routes import user

tests/test_celery.py

@@ -1,9 +1,9 @@
 from unittest.mock import patch
 from application.core.settings import settings
-from application.celery import make_celery
+from application.celery_init import make_celery
 
 
-@patch('application.celery.Celery')
+@patch('application.celery_init.Celery')
 def test_make_celery(mock_celery):
     # Arrange
     app_name = 'test_app_name'