flytekit.interfaces.stats.taggable

Directory

Classes

flytekit.interfaces.stats.taggable.StatsConfig

Configuration for sending statsd.

def StatsConfig(
    host: str,
    port: int,
    disabled: bool,
    disabled_tags: bool,
):

Methods

auto()

def auto(
    config_file: typing.Union[str, ConfigFile],
):

Reads from environment variable, followed by ConfigFile provided

flytekit.interfaces.stats.taggable.TaggableStats

A Proxy object for an underlying statsd client. Adds a new call, scope(prefix), which returns a new proxy to the same client which will prefix all calls to underlying methods with the scoped prefix: new_client = client.get_stats(‘a’) new_client.incr(‘b’) # Metric name = a.b This can be nested: newer_client = new_client.get_stats(‘subsystem’) newer_client.incr(‘bad’) # Metric name = a.subsystem.bad

def TaggableStats(
    client,
    full_prefix,
    cfg: flytekit.configuration.StatsConfig,
    prefix,
    tags,
):

Methods

clear_tags()

def clear_tags()

extend_tags()

def extend_tags(
    tags,
):

get_stats()

def get_stats(
    name,
    copy_tags,
):

pipeline()

def pipeline()

Properties