()
\b
        - DESCRIPTION:
            Check for Flow server status and Flow version.

        \b
        - USAGE:
            pipeline config check
\b
        - DESCRIPTION:
            Check for Flow server status and Flow version.
\ b - DESCRIPTION : Check for Flow server status and Flow version .
def _check():
    """
        \b
        - DESCRIPTION:
            Check for Flow server status and Flow version.

        \b
        - USAGE:
            pipeline config check
    """
    from pipeline.backend import config as conf
    if conf.FlowConfig.IP is None:
        click.echo(f"Flow server ip not yet configured. Please specify setting with pipeline initialization tool.")
        return
    if conf.FlowConfig.PORT is None:
        click.echo(f"Flow server port not yet configured. Please specify setting with pipeline initialization tool.")

    client = FlowClient(ip=conf.FlowConfig.IP, port=conf.FlowConfig.PORT, version=conf.SERVER_VERSION)
    version = client.remote_version.fate_flow()
    if version is None:
        click.echo(f"Flow server not responsive. Please check flow server ip and port setting.")
    else:
        click.echo(f"Flow server status normal, Flow version: {version}")
def _check ( ) : from pipeline . backend import config as conf if conf . FlowConfig . IP is None : click . echo ( f"Flow server ip not yet configured. Please specify setting with pipeline initialization tool." ) return if conf . FlowConfig . PORT is None : click . echo ( f"Flow server port not yet configured. Please specify setting with pipeline initialization tool." ) client = FlowClient ( ip = conf . FlowConfig . IP , port = conf . FlowConfig . PORT , version = conf . SERVER_VERSION ) version = client . remote_version . fate_flow ( ) if version is None : click . echo ( f"Flow server not responsive. Please check flow server ip and port setting." ) else : click . echo ( f"Flow server status normal, Flow version: {version}" )