using Subprocess to avoid long-running task from disconnecting discord.py bot?

by

praw relies on the requests library, which is synchronous meaning that the code is blocking. This can cause your bot to freeze if the blocking code takes too long to execute.

To get around this, a separate thread can be created that handles the blocking code. Below is an example of this. Note how blocking_function will use time.sleep to block for 10 minutes (600 seconds). This should be more than enough to freeze and eventually crash the bot. However, since the function is in it’s own thread using run_in_executor, the bot continues to operate as normal.

New versions

import time
import asyncio
from discord.ext import commands
from concurrent.futures import ThreadPoolExecutor

def blocking_function():
    print('entering blocking function')
    time.sleep(600)
    print('sleep has been completed')
    return 'Pong'

client = commands.Bot(command_prefix='!')

@client.event
async def on_ready():
    print('client ready')

@client.command()
async def ping(ctx):
    loop = asyncio.get_event_loop()
    block_return = await loop.run_in_executor(ThreadPoolExecutor(), blocking_function)
    await ctx.send(block_return)

client.run('token')

Older async version

import time
import asyncio
from discord.ext import commands
from concurrent.futures import ThreadPoolExecutor

def blocking_function():
    print('entering blocking function')
    time.sleep(600)
    print('sleep has been completed')
    return 'Pong'

client = commands.Bot(command_prefix='!')

@client.event
async def on_ready():
    print('client ready')

@client.command()
async def ping():
    loop = asyncio.get_event_loop()
    block_return = await loop.run_in_executor(ThreadPoolExecutor(), blocking_function)
    await client.say(block_return)

client.run('token')

More Related Contents:

  1. Last unbuffered line can’t be read
  2. Python async: Waiting for stdin input while doing other stuff
  3. How i can get new ip from tor every requests in threads?
  4. Discord Music bot VoiceClient’ object has no attribute ‘create_ytdl_player’
  5. Fetching multiple urls with aiohttp in python
  6. Could someone please go through this code line by line and explain it in Pseudocode or English
  7. How to change the location of the column name in pandas?
  8. How to retrieve the text of a WebElement using Selenium – Python
  9. What does sys.intern() do and when should it be used?
  10. DeprecationWarning: executable_path has been deprecated, please pass in a Service object
  11. asyncio.sleep() vs time.sleep()
  12. Why does loading tensorflow on Mac lead to “Process finished with exit code 132 (interrupted by signal 4: SIGILL)”?
  13. Print doesn’t print when it’s in map, Python
  14. How to use asyncio with existing blocking library?
  15. Simplest async/await example possible in Python
  16. ImportError: No module named ‘psycopg2._psycopg’
  17. Error when executing `jupyter notebook` (No such file or directory)
  18. TypeError: can’t pickle _thread.lock objects
  19. Optimize Sieve of Eratosthenes Further
  20. How to call an async function without await?
  21. How to replace the icon in a Tkinter app?
  22. How to click on the anchor element when the spinner obscures it using Selenium and Python?
  23. How to make python 3 print() utf8
  24. Pandas pd.cut() – binning datetime column / series
  25. Permission Error When Trying to Use PyInstaller
  26. Keras, Tensorflow : Merge two different model output into one
  27. How to bypass being rate limited ..HTML Error 1015 using Python
  28. Debugging Numpy VisibleDeprecationWarning (ndarray from ragged nested sequences)
  29. how to add a coroutine to a running asyncio loop?
  30. How to determine what version of python3 tkinter is installed on my linux machine?

Leave a Comment