Prometheus (dagster-prometheus)

dagster_prometheus.PrometheusResource ResourceDefinition

This resource is used to send metrics to a Prometheus Pushgateway.

Example:

from dagster_prometheus import PrometheusResource
from dagster import Definitions, job, op

@op
def example_prometheus_op(prometheus: PrometheusResource):
    prometheus.push_to_gateway(job="my_job")

@job
def my_job():
    example_prometheus_op()

defs = Definitions(
    jobs=[my_job],
    resources=\{"prometheus": PrometheusResource(gateway="http://pushgateway.local")},
)

class dagster_prometheus.resources.PrometheusClient

Integrates with Prometheus via the prometheus_client library.

Legacy

dagster_prometheus.prometheus_resource ResourceDefinition