patch.py

import functools

def async_compat(func):
    @functools.wraps(func)
    def wrapper_decorator(*args, **kwargs):
        version = sys.version_info[0] + sys.version_info[1] / 10.0
        if version >= 3.7:
            kwargs['is_async'] = kwargs.get('async', False)
            del kwargs['async']
        return func(*args, **kwargs)
    return wrapper_decorator

@async_compat
def start_stream(stream, **kwargs):
    """Start the stream, prints the disconnection error
    
    Args:
        stream (obj): stream object to start
    """
    try:
        stream.filter(**kwargs)
    except Exception:
        stream.disconnect()
        print("Fatal exception")