tgbot-collection/ytdlbot
1
1
Fork 0
mirror of https://github.com/tgbot-collection/ytdlbot.git synced 2024-09-20 15:05:56 +08:00
Code Issues Packages Projects Releases Wiki Activity

create celery app, not in-memory

Browse source
This commit is contained in:
Benny 2022-12-27 21:57:33 +01:00
parent f4d9974cb3
commit 67ad5a6bd9
No known key found for this signature in database
GPG key ID: 6CD0DBDA5235D481
4 changed files with 6 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
.gitignore vendored
View file

@ -155,7 +155,8 @@ db_data/*
env/*
.ash_history
.DS_Store
ytdlbot/ytdl.session
ytdlbot/session/ytdl.session
ytdlbot/session/celery.session
data/*
upgrade_worker.sh
ytdl.session

2
ytdlbot/client_init.py
View file

@ -14,7 +14,7 @@ from pyrogram import Client
from config import APP_HASH, APP_ID, PYRO_WORKERS, TOKEN, IPv6
def create_app(session="ytdl", workers=PYRO_WORKERS):
def create_app(session="session/ytdl", workers=PYRO_WORKERS):
_app = Client(session, APP_ID, APP_HASH,
bot_token=TOKEN, workers=workers,
ipv6=IPv6,

1
ytdlbot/session/readme.txt Normal file
View file

@ -0,0 +1 @@
dir for session files.

2
ytdlbot/tasks.py
View file

@ -51,7 +51,7 @@ logging.getLogger('apscheduler.executors.default').propagate = False
# app = Celery('celery', broker=BROKER, accept_content=['pickle'], task_serializer='pickle')
app = Celery('tasks', broker=BROKER)
celery_client = create_app(":memory:")
celery_client = create_app("session/celery")
def get_messages(chat_id, message_id):