| from App import bot | |
| from fastapi import UploadFile | |
| from App.Transcription.Model import Transcriptions | |
| import subprocess | |
| async def perform_background_task(file_name: str, file: UploadFile, task_id: str): | |
| data = await bot.send_file( | |
| -1001925049183, file_size=file.size, caption=file.filename, file=file_name | |
| ) | |
| # get entry and update | |
| entry: Transcriptions = await Transcriptions.objects.filter(task_id=task_id).first() | |
| await entry.update(tl_file_id=str(data.id)) | |
| def download_with_wget(link, download_dir, filename): | |
| subprocess.run(["aria2c", link, "-d", download_dir, "-o", filename]) | |