diff --git a/binaries/coordinator/src/control.rs b/binaries/coordinator/src/control.rs index 3b254ca5..e0a0bd5a 100644 --- a/binaries/coordinator/src/control.rs +++ b/binaries/coordinator/src/control.rs @@ -112,6 +112,7 @@ enum HandlerError { ServerStopped, } +#[derive(Debug)] pub enum ControlEvent { IncomingRequest { request: ControlRequest, diff --git a/binaries/coordinator/src/lib.rs b/binaries/coordinator/src/lib.rs index 8c3fe678..d3c1c014 100644 --- a/binaries/coordinator/src/lib.rs +++ b/binaries/coordinator/src/lib.rs @@ -77,6 +77,7 @@ async fn start(runtime_path: &Path) -> eyre::Result<()> { let mut running_dataflows = HashMap::new(); while let Some(event) = events.next().await { + tracing::trace!("Handling event {event:?}"); match event { Event::Dataflow { uuid, event } => match event { DataflowEvent::Finished { result } => { @@ -319,11 +320,13 @@ async fn start_dataflow( }) } +#[derive(Debug)] enum Event { Dataflow { uuid: Uuid, event: DataflowEvent }, Control(ControlEvent), } +#[derive(Debug)] enum DataflowEvent { Finished { result: eyre::Result<()> }, }