Function run

python/pathway/internals/run.py:13–62

Runs the computation graph. Args: debug: enable output out of table.debug() operators monitoring_level: the verbosity of stats monitoring mechanism. One of pathway.MonitoringLevel.NONE, pathway.MonitoringLevel.IN_OUT, pathway.MonitoringLevel.ALL. If unset

(
    *,
    debug: bool = False,
    monitoring_level: MonitoringLevel = MonitoringLevel.AUTO,
    with_http_server: bool = False,
    default_logging: bool = True,
    persistence_config: PersistenceConfig | None = None,
    runtime_typechecking: bool | None = None,
    terminate_on_error: bool | None = None,
    max_expression_batch_size: int = 1024,
    event_loop: asyncio.AbstractEventLoop | None = None,
)

@check_arg_types
def run(
    *,
    debug: bool = False,
    monitoring_level: MonitoringLevel = MonitoringLevel.AUTO,
    with_http_server: bool = False,
    default_logging: bool = True,
    persistence_config: PersistenceConfig | None = None,
    runtime_typechecking: bool | None = None,
    terminate_on_error: bool | None = None,
    max_expression_batch_size: int = 1024,
    event_loop: asyncio.AbstractEventLoop | None = None,
) -> None:
    """Runs the computation graph.

    Args:
        debug: enable output out of table.debug() operators
        monitoring_level: the verbosity of stats monitoring mechanism. One of
            pathway.MonitoringLevel.NONE, pathway.MonitoringLevel.IN_OUT,
            pathway.MonitoringLevel.ALL. If unset, pathway will choose between
            NONE and IN_OUT based on output interactivity.
        with_http_server: whether to start a http server with runtime metrics. [will be deprecated soon]
            Learn more about Pathway Live Data Framework monitoring in a
            `tutorial </developers/user-guide/deployment/pathway-monitoring/>`_ .
        default_logging: whether to allow pathway to set its own logging handler. Set
            it to False if you want to set your own logging handler.
        persistence_config: the config for persisting the state in case this
            persistence is required.
        runtime_typechecking: enables additional strict type checking at runtime
        terminate_on_error: whether to terminate the computation if the data/user-logic error occurs
        max_expression_batch_size: the maximal number of rows for which the expressions
            are computed at once. You might want to decrease it if the intermediate state
            in one of your expressions is large.
        event_loop: an externally created event loop to use for the duration of the run.
            If not specified, a new event loop is created and closed automatically.
            When running the graph multiple times with async UDFs that use ``InMemoryCache``,
            the same event loop must be provided to all runs to avoid runtime errors.
    """
    GraphRunner(
        parse_graph.G,
        debug=debug,
        monitoring_level=monitoring_level,
        with_http_server=with_http_server,
        default_logging=default_logging,
        persistence_config=persistence_config,
        runtime_typechecking=runtime_typechecking,
        terminate_on_error=terminate_on_error,
        max_expression_batch_size=max_expression_batch_size,
        event_loop=event_loop,
        _stacklevel=4,
    ).run_outputs()


@check_arg_types