yasirarism/MissKatyPyro
1
0
Fork 0
mirror of https://github.com/yasirarism/MissKatyPyro.git synced 2026-01-03 11:04:51 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

One task per user

Browse source
This commit is contained in:
yasir 2023-01-28 11:43:04 +07:00
parent c7b0b25c08
commit 1a89ecc7b5
2 changed files with 7 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
misskaty/plugins/genss.py
View file

@ -45,7 +45,7 @@ async def genss(client, message):
if not DL_TASK.get(message.from_user.id): if not DL_TASK.get(message.from_user.id):
DL_TASK[message.from_user.id] = Lock() DL_TASK[message.from_user.id] = Lock()
if DL_TASK[message.from_user.id].locked(): if DL_TASK.get(message.from_user.id):
return await process.edit("Sorry to avoid flood and error, bot only process one task at a time.") return await process.edit("Sorry to avoid flood and error, bot only process one task at a time.")
c_time = time.time() c_time = time.time()
the_real_download_location = await replied.download( the_real_download_location = await replied.download(

11
misskaty/plugins/mediainfo.py
View file

@ -29,12 +29,13 @@ async def mediainfo(client, message):
file_info = get_file_id(message.reply_to_message) file_info = get_file_id(message.reply_to_message)
if file_info is None: if file_info is None:
return await process.edit_text("Balas ke format media yang valid") return await process.edit_text("Balas ke format media yang valid")
if not DL_TASK.get(message.from_user.id): async with DL_TASK:
DL_TASK[message.from_user.id] = asyncio.Lock() if not DL_TASK.get(message.from_user.id):
DL_TASK[message.from_user.id] = asyncio.Lock()
if DL_TASK[message.from_user.id].locked(): if DL_TASK.get(message.from_user.id):
return await process.edit("Sorry to avoid flood and error, bot only process one task at a time.") return await process.edit("Sorry to avoid flood and error, bot only process one task at a time.")
c_time = time.time() c_time = time.time()
file_path = await message.reply_to_message.download( file_path = await message.reply_to_message.download(
progress=progress_for_pyrogram, progress=progress_for_pyrogram,