diff --git a/requirements.txt b/requirements.txt index 3f6981c..c68cd31 100644 --- a/requirements.txt +++ b/requirements.txt @@ -8,7 +8,7 @@ sqlalchemy[asyncio] asyncpg alembic python-dotenv -aiohttp +aiohttp==3.11.18 aiohttp[speedups] celery[redis] pyjwt @@ -20,4 +20,4 @@ gevent taskiq-aio-pika==0.4.2 taskiq-fastapi==0.3.5 taskiq==0.11.17 -taskiq-pipelines \ No newline at end of file +taskiq-pipelines diff --git a/start_scheduler.sh b/start_scheduler.sh old mode 100644 new mode 100755 diff --git a/start_scheduler_background.sh b/start_scheduler_background.sh new file mode 100755 index 0000000..0de307b --- /dev/null +++ b/start_scheduler_background.sh @@ -0,0 +1,4 @@ +#!/bin/bash +SCRIPT_PATH="$(cd "$(dirname "$0")" && pwd)" +source $SCRIPT_PATH/venv/bin/activate +bash $SCRIPT_PATH/start_scheduler.sh diff --git a/start_taskiq.sh b/start_taskiq.sh index 9499076..ca7cc55 100755 --- a/start_taskiq.sh +++ b/start_taskiq.sh @@ -54,7 +54,7 @@ fi # Start the Taskiq worker log_info "Starting Taskiq worker..." -taskiq worker background:taskiq_broker background.tasks --max-async-task 5000 --max-threadpool-threads 8 --max-prefetch 10000 --workers 1 +taskiq worker background:taskiq_broker background.tasks --max-async-task 1000 --max-threadpool-threads 8 --max-prefetch 10000 --workers 1 # Log when the Taskiq worker stops -log_info "Taskiq worker stopped" \ No newline at end of file +log_info "Taskiq worker stopped" diff --git a/start_taskiq_background.sh b/start_taskiq_background.sh new file mode 100755 index 0000000..8ffe01d --- /dev/null +++ b/start_taskiq_background.sh @@ -0,0 +1,4 @@ +#!/bin/bash +SCRIPT_PATH="$(cd "$(dirname "$0")" && pwd)" +source $SCRIPT_PATH/venv/bin/activate +bash $SCRIPT_PATH/start_taskiq.sh