Python blocking calls in async code

example.py

import twitter
import asyncio
import time

CONSUMER_KEY = ''
CONSUMER_SECRET = ''
ACCESS_TOKEN_KEY = ''
ACCESS_TOKEN_SECRET = ''


def getTweetsBlocking(api, term):
    """
    Esta sería la llamada normal (bloqueante) a la API de Twitter
    """

    print(f"Search started for {term}")
    tweets = api.GetSearch(raw_query=f"q={term}&count=500")
    print(f"Search done for {term}")


async def getTweets(api, term):
    """
    En esta función asíncrona ejecutamos la función bloqueante (getTweetsBlocking)
    dentro de un "executor", de forma que esta función (getTweets) no es bloqueante.
    """

    loop = asyncio.get_event_loop()
    await loop.run_in_executor(None, getTweetsBlocking, api, term)


async def main():
    api = twitter.Api(
        consumer_key=CONSUMER_KEY,
        consumer_secret=CONSUMER_SECRET,
        access_token_key=ACCESS_TOKEN_KEY,
        access_token_secret=ACCESS_TOKEN_SECRET,
    )

    # El método "gather" ejecuta de forma concurrente todas las funciones
    # asíncronas que le pasemos y termina cuando todas hayan terminado.
    await asyncio.gather(
        getTweets(api, "Madrid"),
        getTweets(api, "Barcelona"),
        getTweets(api, "Valencia"),
        getTweets(api, "Sevilla"),
    )

    print("All searchs finished")


asyncio.run(main())