Requests.Session -> Async

standard_api_client.py

import requests

class MyApiClient(requests.Session):
  def do_something(self):
    response = self.post('/some/url', json={
      'param1': 'a',
      'param2': 'b'
    })
    
    if response.status_code == requests.codes.ok:
      return response.json()
    
    raise ValueError("invalid API response")

standard_api_client_plus_async.py

import requests

class AsyncSession(requests.Session):
  def request(self, *args, **kwargs):
    if 'async' in kwargs:
      async = kwargs['async']
      del kwargs['async']
    else:
      async = False
    
    future = super().request(*args, **kwargs)
    
    if async:
      return future.result()
    
    return future
  
class MyApiClient(AsyncSession):
  def do_something(self):
    """ Code remains unchanged from example above. """

  def do_something_async(self):
    future = self.post('/some/url', async=True, json={
      'param1': 'a',
      'param2': 'b'
    })

    return future