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}")