use session

.gitignore

@@ -166,3 +166,7 @@ reinforcement/*
 /ytdlbot/session/ytdl.session-journal
 /ytdlbot/unknown_errors.txt
 /ytdlbot/ytdl.session-journal
+/ytdlbot/ytdl-main.session-journal
+/ytdlbot/ytdl-main.session
+/ytdlbot/ytdl-celery.session-journal
+/ytdlbot/ytdl-celery.session

ytdlbot/client_init.py

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

ytdlbot/tasks.py

@@ -39,9 +39,9 @@
     BROKER,
     ENABLE_CELERY,
     ENABLE_QUEUE,
-    RATE_LIMIT,
     ENABLE_VIP,
     OWNER,
+    RATE_LIMIT,
     TG_MAX_SIZE,
     WORKERS,
 )
@@ -68,7 +68,9 @@
 app = Celery("tasks", broker=BROKER)
 redis = Redis()
 channel = Channel()
-celery_client = create_app(":memory:")
+
+session = "ytdl-celery"
+celery_client = create_app(session)
 
 
 def get_messages(chat_id, message_id):
@@ -481,7 +483,7 @@ def purge_tasks():
 
 
 if __name__ == "__main__":
-    celery_client.start()
+    # celery_client.start()
     print("Bootstrapping Celery worker now.....")
     time.sleep(5)
     threading.Thread(target=run_celery, daemon=True).start()

ytdlbot/ytdl_bot.py

@@ -54,7 +54,8 @@
 customize_logger(["pyrogram.client", "pyrogram.session.session", "pyrogram.connection.connection"])
 logging.getLogger("apscheduler.executors.default").propagate = False
 
-app = create_app(":memory:")
+session = "ytdl-main"
+app = create_app(session)
 
 logging.info("Authorized users are %s", AUTHORIZED_USER)
 redis = Redis()