Augment

This module contains functionality related to the the augment script.

Augment

This script is used to handle chat interactions using the ChainLit library and a chat engine. Actions are observed by Langfuse. To make it work vector storage should be filled with the embeddings of the documents. To run the script execute the following command from the root directory of the project:

python src/chat.py

get_cached_initializer()

Initialize the augmentation process and cache it the initializer.

Source code in src/augment.py 
22
23
24
25
26
27
@cl.cache
def get_cached_initializer() -> AugmentationInitializer:
    """
    Initialize the augmentation process and cache it the initializer.
    """
    return AugmentationInitializer()

get_data_layer()

Initialize Chainlit's data layer with the custom service.

Returns:
  • ChainlitService( ChainlitService ) –

    The custom service for data layer.
Source code in src/augment.py 
30
31
32
33
34
35
36
37
38
39
@cl.data_layer
def get_data_layer() -> ChainlitService:
    """
    Initialize Chainlit's data layer with the custom service.

    Returns:
        ChainlitService: The custom service for data layer.
    """
    configuration = get_cached_initializer().get_configuration()
    return ChainlitServiceFactory.create(configuration.augmentation)

main(user_message) async

Process user messages and generate responses.

Parameters:
  • user_message (Message) –

    Message received from user
Source code in src/augment.py 
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
@cl.on_message
async def main(user_message: cl.Message) -> None:
    """
    Process user messages and generate responses.

    Args:
        user_message: Message received from user
    """
    chat_engine = cl.user_session.get("chat_engine")
    assistant_message = cl.Message(content="", author="Assistant")
    response = await cl.make_async(chat_engine.stream_chat)(
        message=user_message.content,
        chainlit_message_id=assistant_message.parent_id,
    )
    for token in response.response_gen:
        await assistant_message.stream_token(token)

    configuration = get_cached_initializer().get_configuration()
    utils = ChainlitUtilsFactory.create(configuration.augmentation.chainlit)
    utils.add_references(assistant_message, response)
    await assistant_message.send()

start() async

Initialize chat session with chat engine. Sets up session-specific chat engine and displays welcome message.

Source code in src/augment.py 
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
@cl.on_chat_start
async def start() -> None:
    """
    Initialize chat session with chat engine.
    Sets up session-specific chat engine and displays welcome message.
    """
    initializer = get_cached_initializer()
    configuration = initializer.get_configuration()

    chat_engine = ChatEngineRegistry.get(
        configuration.augmentation.chat_engine.name
    ).create(configuration)
    chat_engine.set_session_id(cl.user_session.get("id"))
    cl.user_session.set("chat_engine", chat_engine)

    utils = ChainlitUtilsFactory.create(configuration.augmentation.chainlit)
    await utils.get_welcome_message().send()