From 7ce86a3cfbcdb5869d25df0fdf8cb0862a267aa2 Mon Sep 17 00:00:00 2001
From: Philipp Oppermann <dev@phil-opp.com>
Date: Wed, 7 Dec 2022 14:10:35 +0100
Subject: [PATCH] Log received control events

---
 binaries/coordinator/src/control.rs | 1 +
 binaries/coordinator/src/lib.rs     | 3 +++
 2 files changed, 4 insertions(+)

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<()> },
 }