Calling sqlmesh run equivalent directly from the code

[jukiewiczm]

Is there a cleaner/more proper way of doing this than:

ctx = Context()
completion_status = ctx.run()

?

I'm trying to get this done as a part of the pipeline I'm running (the last step of it) and it causes some problems. Especially:

• logs are sometimes missing (for the reasons I haven't discovered yet)
• can't really get the errors into a variable (the CompletionStatus doesn't have them)

[jukiewiczm]

For anyone interested, this is what I ended up doing to catch the errors and keep the logging consistent.

from sqlmesh.core.console import CaptureTerminalConsole, RichConsole
from sqlmesh.core.context import Context

console = CaptureTerminalConsole(RichConsole())
ctx = Context()
ctx.console = console
completion_status = ctx.run()

logger.info(f"Run finished.\nLogged output:\n{console.captured_output}")

if completion_status.is_failure:
    raise Exception(f"{console.captured_errors}")