Function run_tasks

api/app/api/routes.py:69–75

()

    natural_language_query = replace_unsupported_localities(natural_language_query, scope)

    async def run_tasks():
        relevant_tables_task = asyncio.create_task(get_relevant_tables_async(natural_language_query, scope, session_id = session_id))
        labels_task = asyncio.create_task(create_labels(natural_language_query, scope, parent_id=parent_id, session_id = session_id))

        table_names = await relevant_tables_task
        generation_id = await labels_task
        return table_names, generation_id

    table_names, generation_id = asyncio.run(run_tasks())