luigi.metrics

Classes

`MetricsCollector`()	Abstractable MetricsCollector base class that can be replace by tool specific implementation.
`MetricsCollectors`(*values)
`NoMetricsCollector`()	Empty MetricsCollector when no collector is being used

class luigi.metrics.MetricsCollectors(*values)[source]

custom = -1

default = 1

none = 1

datadog = 2

prometheus = 3

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

class luigi.metrics.MetricsCollector[source]

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

abstractmethod handle_task_started(task)[source]

abstractmethod handle_task_failed(task)[source]

abstractmethod handle_task_disabled(task, config)[source]

abstractmethod handle_task_done(task)[source]

handle_task_statistics(task, statistics)[source]

generate_latest()[source]

configure_http_handler(http_handler)[source]

class luigi.metrics.NoMetricsCollector[source]

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]