flytekit.interfaces.stats.taggable

Directory

Classes

Methods

Methods

get_stats()

def get_stats(
    cfg: flytekit.configuration.StatsConfig,
    prefix: str,
    tags: typing.Dict[str, str],
) -> e: TaggableStats

:rtype: TaggableStats

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

class 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