Skip to content

Commit

Permalink
wip
Browse files Browse the repository at this point in the history
  • Loading branch information
Nick authored and Nick committed May 13, 2024
1 parent 31a3177 commit fa5ef31
Show file tree
Hide file tree
Showing 3 changed files with 16 additions and 6 deletions.
4 changes: 0 additions & 4 deletions Cargo.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

2 changes: 1 addition & 1 deletion Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -49,7 +49,7 @@ members = [
"crates/chain-data",
"crates/types",
"crates/core-manager",
"crates/log-format", "~/projects/fluencelabs/aqua-sandbox/aqua",
"crates/log-format",
]
exclude = [
"nox/tests/tetraplets",
Expand Down
16 changes: 15 additions & 1 deletion crates/workers/src/workers.rs
Original file line number Diff line number Diff line change
Expand Up @@ -238,8 +238,22 @@ impl Workers {
.await
.map_err(|_err| WorkersError::FailedToNotifySubsystem { worker_id });
match result {
Ok(_) => Ok(()),
Ok(_) => {
tracing::info!(
target = "worker-registry",
worker_id = worker_id.to_string(),
"Worker {worker_id} created"
);
Ok(())
}
Err(err) => {
tracing::warn!(
target = "worker-registry",
worker_id = worker_id.to_string(),
"Failed to notify subsystem for {worker_id}: {}",
err
);

let mut worker_ids = self.worker_ids.write();
let mut worker_infos = self.worker_infos.write();
let mut runtimes = self.runtimes.write();
Expand Down

0 comments on commit fa5ef31

Please sign in to comment.