<commit_before>from gabriel_protocol import gabriel_pb2
from gabriel_client.websocket_client import WebsocketClient
from gabriel_client.websocket_client import ProducerWrapper
import asyncio


def main():
    async def producer():

        # Do not use time.sleep. This would stop the event loop.
        await asyncio.sleep(1)
        return gabriel_pb2.InputFrame()

    def consumer(_):
        pass

    producer_wrappers = [
        ProducerWrapper(producer=producer, source_name='empty')
    ]
    client = WebsocketClient(
        host='localhost', port=9099, producer_wrappers=producer_wrappers,
        consumer=consumer)
    client.launch()


if __name__ == '__main__':
    main()<commit_msg>Update client.py<commit_after>from gabriel_protocol import gabriel_pb2
from gabriel_client.websocket_client import WebsocketClient
from gabriel_client.websocket_client import ProducerWrapper
import asyncio


def main():
    async def producer():

        # Do not use time.sleep. This would stop the event loop.
        await asyncio.sleep(1)

        return gabriel_pb2.InputFrame()

    def consumer(_):
        pass

    producer_wrappers = [
        ProducerWrapper(producer=producer, source_name='empty')
    ]
    client = WebsocketClient(
        host='localhost', port=9099, producer_wrappers=producer_wrappers,
        consumer=consumer)
    client.launch()


if __name__ == '__main__':
    main()
{'fraction_non_alphanumeric': 0.08025568181818182, 'fraction_numerical': 0.009943181818181818, 'mean_word_length': 3.516025641025641, 'pattern_counts': {'":': 0, '<': 3, '<?xml version=': 0, '>': 3, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 0, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '7370355', 'n_tokens_mistral': 429, 'n_tokens_neox': 425, 'n_words': 100}