From 80e5bcaac41d3ba355cd6e1691707996b9f09a67 Mon Sep 17 00:00:00 2001 From: Milind Srivastava Date: Fri, 26 Jun 2026 18:37:26 -0400 Subject: [PATCH] fix(tools): update .start() to use DiscoveryBackend instead of prometheus_url --- asap-tools/experiments/experiment_only_ingest_path.py | 7 ++++++- asap-tools/experiments/experiment_run_grafana_demo.py | 7 ++++++- 2 files changed, 12 insertions(+), 2 deletions(-) diff --git a/asap-tools/experiments/experiment_only_ingest_path.py b/asap-tools/experiments/experiment_only_ingest_path.py index dc3cbf6..41af9d9 100644 --- a/asap-tools/experiments/experiment_only_ingest_path.py +++ b/asap-tools/experiments/experiment_only_ingest_path.py @@ -23,6 +23,7 @@ PrometheusHealthMonitor, ControllerService, ) +from experiment_utils.services.misc import DiscoveryBackend # Register custom resolver for LOCAL_EXPERIMENT_DIR before Hydra processes config OmegaConf.register_new_resolver( @@ -303,7 +304,11 @@ def main(cfg: DictConfig): streaming_engine=args.streaming_engine, controller_remote_output_dir=CONTROLLER_REMOTE_OUTPUT_DIR, punting=args.controller_punting, - prometheus_url=prometheus_url, + discovery_backend=DiscoveryBackend( + type="prometheus", + url=prometheus_url, + database=None, + ), ) sync.rsync_controller_config_remote_to_local( provider, diff --git a/asap-tools/experiments/experiment_run_grafana_demo.py b/asap-tools/experiments/experiment_run_grafana_demo.py index 6eff1a2..589fe82 100644 --- a/asap-tools/experiments/experiment_run_grafana_demo.py +++ b/asap-tools/experiments/experiment_run_grafana_demo.py @@ -27,6 +27,7 @@ SystemExportersService, GrafanaService, ) +from experiment_utils.services.misc import DiscoveryBackend COMPRESS_JSON = True GRAFANA_ADMIN_PASSWORD = "admin" @@ -356,7 +357,11 @@ def main(cfg: DictConfig): streaming_engine=args.streaming_engine, controller_remote_output_dir=CONTROLLER_REMOTE_OUTPUT_DIR, punting=args.controller_punting, - prometheus_url=prometheus_url, + discovery_backend=DiscoveryBackend( + type="prometheus", + url=prometheus_url, + database=None, + ), ) sync.rsync_controller_config_remote_to_local( provider,