luigi.metrics module¶

class luigi.metrics.MetricsCollectors(value)[source]¶

Bases: Enum

An enumeration.

custom = -1¶

default = 1¶

none = 1¶

datadog = 2¶

prometheus = 3¶

classmethod get(which, custom_import=None)[source]¶

class luigi.metrics.MetricsCollector[source]¶

Bases: object

Abstractable MetricsCollector base class that can be replace by tool specific implementation.

abstract handle_task_started(task)[source]¶

abstract handle_task_failed(task)[source]¶

abstract handle_task_disabled(task, config)[source]¶

abstract handle_task_done(task)[source]¶

generate_latest()[source]¶

configure_http_handler(http_handler)[source]¶

class luigi.metrics.NoMetricsCollector[source]¶

Bases: MetricsCollector

Empty MetricsCollector when no collector is being used

handle_task_started(task)[source]¶

handle_task_failed(task)[source]¶

handle_task_disabled(task, config)[source]¶

handle_task_done(task)[source]¶