Remove DependencyManager as it was no longer used

Author: mortenhaahr

src/benches_common.rs

@@ -13,7 +13,6 @@ use crate::core::OutputHandler;
 use crate::core::Runnable;
 use crate::core::Runtime;
 use crate::core::Semantics;
-use crate::dep_manage::interface::DependencyManager;
 use crate::io::testing::null_output_handler::{LimitedNullOutputHandler, NullOutputHandler};
 use crate::lang::dynamic_lola::type_checker::TypedLOLASpecification;
 use crate::runtime::RuntimeBuilder;
@@ -28,7 +27,6 @@ pub async fn monitor_runtime_outputs(
     executor: Rc<LocalExecutor<'static>>,
     spec: LOLASpecification,
     input_streams: BTreeMap<VarName, OutputStream<Value>>,
-    dep_manager: DependencyManager,
     output_limit: Option<usize>,
 ) {
     let output_handler: Box<dyn OutputHandler<Val = Value>> = match output_limit {
@@ -50,7 +48,6 @@ pub async fn monitor_runtime_outputs(
         .model(spec)
         .output(output_handler)
         .input(Box::new(input_streams))
-        .dependencies(dep_manager)
         .build();
     monitor.run().await.expect("Error running monitor");
 }
@@ -59,7 +56,6 @@ pub async fn monitor_outputs_untyped_async_limited(
     executor: Rc<LocalExecutor<'static>>,
     spec: LOLASpecification,
     input_streams: BTreeMap<VarName, OutputStream<Value>>,
-    dep_manager: DependencyManager,
     limit: usize,
 ) {
     monitor_runtime_outputs(
@@ -68,7 +64,6 @@ pub async fn monitor_outputs_untyped_async_limited(
         executor,
         spec,
         input_streams,
-        dep_manager,
         Some(limit),
     )
     .await;
@@ -78,15 +73,13 @@ pub async fn monitor_outputs_untyped_async(
     executor: Rc<LocalExecutor<'static>>,
     spec: LOLASpecification,
     input_streams: BTreeMap<VarName, OutputStream<Value>>,
-    dep_manager: DependencyManager,
 ) {
     monitor_runtime_outputs(
         Runtime::Async,
         Semantics::Untimed,
         executor,
         spec,
         input_streams,
-        dep_manager,
         None,
     )
     .await;
@@ -96,7 +89,6 @@ pub async fn monitor_outputs_typed_async(
     executor: Rc<LocalExecutor<'static>>,
     spec: TypedLOLASpecification,
     input_streams: BTreeMap<VarName, OutputStream<Value>>,
-    dep_manager: DependencyManager,
 ) {
     // Currently cannot be deduplicated since it includes the type
     // checking
@@ -115,7 +107,6 @@ pub async fn monitor_outputs_typed_async(
     .model(spec.clone())
     .input(Box::new(input_streams))
     .output(output_handler)
-    .dependencies(dep_manager)
     .build();
     async_monitor.run().await.expect("Error running monitor");
 }

src/core/interfaces.rs

@@ -5,7 +5,7 @@ use clap::ValueEnum;
 use futures::future::LocalBoxFuture;
 use smol::LocalExecutor;
 
-use crate::{dep_manage::interface::DependencyManager, io::mqtt::MQTTLocalityReceiver};
+use crate::io::mqtt::MQTTLocalityReceiver;
 
 use super::{StreamData, VarName};
 
@@ -220,19 +220,6 @@ pub trait AbstractMonitorBuilder<M, V: StreamData> {
         }
     }
 
-    fn dependencies(self, dependencies: DependencyManager) -> Self;
-
-    fn maybe_dependencies(self, dependencies: Option<DependencyManager>) -> Self
-    where
-        Self: Sized,
-    {
-        if let Some(dependencies) = dependencies {
-            self.dependencies(dependencies)
-        } else {
-            self
-        }
-    }
-
     fn mqtt_reconfig_provider(self, provider: MQTTLocalityReceiver) -> Self;
 
     fn maybe_mqtt_reconfig_provider(self, provider: Option<MQTTLocalityReceiver>) -> Self