luigi.metrics module

class luigi.metrics.MetricsCollectors[source]

Bases: enum.Enum

default = 1
none = 1
datadog = 2
prometheus = 3
get = <bound method EnumMeta.get of <enum 'MetricsCollectors'>>[source]
class luigi.metrics.MetricsCollector[source]

Bases: object

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

handle_task_started(task)[source]
handle_task_failed(task)[source]
handle_task_disabled(task, config)[source]
handle_task_done(task)[source]
generate_latest()[source]
configure_http_handler(http_handler)[source]
class luigi.metrics.NoMetricsCollector[source]

Bases: luigi.metrics.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]