|
|
@ -164,6 +164,7 @@ where |
|
|
|
resource,
|
|
|
|
location_prereqs_did_run
|
|
|
|
);
|
|
|
|
|
|
|
|
trace!(logger, "Adding implementation prereqs for {:?}", resource);
|
|
|
|
let impl_prereq_logger = Rc::new(logger.new(o!("prereq" => "implementation")));
|
|
|
|
let (prereqs, prereqs_did_run) = setup
|
|
|
@ -175,23 +176,20 @@ where |
|
|
|
resource,
|
|
|
|
prereqs_did_run
|
|
|
|
);
|
|
|
|
|
|
|
|
trace!(logger, "Running implementation for {:?}", resource);
|
|
|
|
let implementation = B::create(resource, &location, prereqs);
|
|
|
|
let did_run_result = implementation
|
|
|
|
let did_run = implementation
|
|
|
|
.run(
|
|
|
|
&self.symbol_runner,
|
|
|
|
logger,
|
|
|
|
force_run || location_prereqs_did_run || prereqs_did_run,
|
|
|
|
)
|
|
|
|
.await;
|
|
|
|
match did_run_result {
|
|
|
|
Ok(did_run) => {
|
|
|
|
.await?;
|
|
|
|
debug!(logger, "done.");
|
|
|
|
|
|
|
|
Ok((location, did_run))
|
|
|
|
}
|
|
|
|
Err(e) => Err(e),
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
#[async_trait(?Send)]
|
|
|
|