Module pipelines.utils.elasticsearch_metrics.tasks

Tasks for handling Elasticsearch metrics

Functions

def format_metrics(**args)

Formats metrics to be indexed in Elasticsearch

def post_metrics(flow_name: str = None, labels: List[str] = None, event_type: str = None, dataset_id: str = None, table_id: str = None, metrics: Dict[str, Any] = None)

Posts metrics to Elasticsearch

def start_timer() ‑> float

Starts a timer

def stop_timer(start_time: float) ‑> float

Stops a timer