wip

fluencelabs · Nov 27, 2023 · eddc830 · eddc830
1 parent ce0469d
commit eddc830
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/aquamarine/src/plumber.rs b/aquamarine/src/plumber.rs
@@ -107,9 +107,11 @@ impl<RT: AquaRuntime, F: ParticleFunctionStatic> Plumber<RT, F> {
         }
 
         if !self.key_manager.is_worker_active(worker_id)
-            && !self.key_manager.is_management(particle.init_peer_id)
+            && !self
+                .key_manager
+                .is_management(particle.particle.init_peer_id)
         {
-            tracing::trace!(target: "worker_inactive", particle_id = particle.id, worker_id = worker_id.to_string(), "Worker is not active");
+            tracing::trace!(target: "worker_inactive", particle_id = particle.particle.id, worker_id = worker_id.to_string(), "Worker is not active");
             return;
         }