#NEWLINE# @ celery . task ( rate_limit = '10/m' ) #NEWLINE# def broadcast_message( internal_url , data ) : #NEWLINE# #INDENT# "\n    Broadcast the message to anyone listening. We are rate limiting the tweets\n    because otherwise it's nearly impossible to read.\n\n    :param internal_url: Full internal websocket URL\n    :type internal_url: str\n    :param data: Final data to be sent to the websocket server\n    :type data: JSON\n    :return: None\n    " #NEWLINE# from catwatch.blueprints.stream.broadcast import Broadcast #NEWLINE# Broadcast . send_to_websocket_server ( data , data )