From cf45f11257f1b699d7de052a8927d0c1cefb8cd2 Mon Sep 17 00:00:00 2001 From: Philipp Oppermann Date: Mon, 24 Jun 2024 19:00:07 +0200 Subject: [PATCH] Fix example --- examples/multiple-daemons/run.rs | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/examples/multiple-daemons/run.rs b/examples/multiple-daemons/run.rs index c86ae7ed..7dcb1ab8 100644 --- a/examples/multiple-daemons/run.rs +++ b/examples/multiple-daemons/run.rs @@ -2,8 +2,8 @@ use dora_coordinator::{ControlEvent, Event}; use dora_core::{ descriptor::Descriptor, topics::{ - ControlRequest, ControlRequestReply, DataflowId, DataflowList, - DORA_COORDINATOR_PORT_CONTROL_DEFAULT, DORA_COORDINATOR_PORT_DEFAULT, + ControlRequest, ControlRequestReply, DataflowId, DORA_COORDINATOR_PORT_CONTROL_DEFAULT, + DORA_COORDINATOR_PORT_DEFAULT, }, }; use dora_tracing::set_up_tracing; @@ -176,7 +176,7 @@ async fn running_dataflows(coordinator_events_tx: &Sender) -> eyre::Resul .await?; let result = reply.await??; let dataflows = match result { - ControlRequestReply::DataflowList(DataflowList { active, .. }) => active, + ControlRequestReply::DataflowList(list) => list.get_active(), ControlRequestReply::Error(err) => bail!("{err}"), other => bail!("unexpected start dataflow reply: {other:?}"), };