bugfix: renamed database_queue

nfdi4plants · Jul 26, 2024 · ac71b62 · ac71b62
1 parent 6b43b9b
commit ac71b62
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/app/api/endpoints/ontologies.py b/app/api/endpoints/ontologies.py
@@ -39,7 +39,7 @@ async def build_from_scratch():
                 urls.append(url.decode().strip())
 
     for url in urls:
-        chain(add_ontology_task.s(url), add_ontologies.s().set(queue='neo4j_write_queue')).apply_async()
+        chain(add_ontology_task.s(url), add_ontologies.s().set(queue='database_queue')).apply_async()
 
     return Response(status_code=status.HTTP_204_NO_CONTENT)
 

diff --git a/init.sh b/init.sh
@@ -6,7 +6,7 @@ echo "starting swobup..."
 
 echo "starting celery"
 celery -A tasks worker -l info &
-celery -A tasks worker --queues=database_queue --concurrency=1 &
+celery -A tasks worker --queues=database_queue --concurrency=1 -l info &
 celery -A tasks flower -l info --port=1111 &
 echo "starting uvicorn"
 uvicorn --workers 10 --host 0.0.0.0 --port 8000 main:app