Skip to content

Commit

Permalink
v0.4.1 rc (#8)
Browse files Browse the repository at this point in the history
* rust 1.58.1 github ci

* adding more logs
  • Loading branch information
dadleyy authored Jan 21, 2022
1 parent 4f9c311 commit 3297bdc
Show file tree
Hide file tree
Showing 7 changed files with 33 additions and 26 deletions.
2 changes: 1 addition & 1 deletion .github/workflows/build-and-test.yml
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@ jobs:
dist:
runs-on: ubuntu-latest
container:
image: rust:1.57.0
image: rust:1.58.1
steps:
- uses: actions/checkout@v2
- name: Update apt
Expand Down
39 changes: 21 additions & 18 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 workspace/bankah/Cargo.toml
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
[package]
name = "bankah"
version = "0.4.0"
version = "0.4.1"
edition = "2018"

[dependencies]
Expand Down
2 changes: 1 addition & 1 deletion workspace/stickbot/Cargo.toml
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
[package]
name = "stickbot"
version = "0.4.0"
version = "0.4.1"
edition = "2018"

[lib]
Expand Down
5 changes: 4 additions & 1 deletion workspace/stickbot/src/bin/boxbot.rs
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,10 @@ use bankah::jobs::{TableAdminJob, TableJob};
async fn work(services: &stickbot::Services) -> Result<()> {
let job = match services.pop().await? {
Some(job) => job,
None => return Ok(()),
None => {
log::debug!("no job returned from queue");
return Ok(());
}
};

log::debug!("deserialized job from queue - {:?}", job);
Expand Down
7 changes: 4 additions & 3 deletions workspace/stickbot/src/services.rs
Original file line number Diff line number Diff line change
Expand Up @@ -82,7 +82,7 @@ impl Services {
return Err(Error::new(ErrorKind::Other, format!("{}", error)));
}
Ok(kramer::Response::Item(kramer::ResponseValue::Empty)) => {
log::debug!("empty response from queue, moving on");
log::debug!("empty response from queue");
return Ok(None);
}
Ok(kramer::Response::Array(values)) => values,
Expand Down Expand Up @@ -173,9 +173,10 @@ impl Services {
V: std::fmt::Display,
{
loop {
log::debug!("requesting tcp write access trhough lock");
let mut lock = self.redis.lock().await;
let mut redis: &mut TcpStream = &mut lock;
log::trace!("attempting to send command to redis - {}", command);
log::debug!("lock acquired, attempting to send command");
let result = kramer::execute(&mut redis, command).await;

if attempt > 10 {
Expand All @@ -195,7 +196,7 @@ impl Services {
}

if let Ok(response) = result {
log::trace!("redis command executed successfully - {:?}", response);
log::debug!("redis command executed successfully - {:?}", response);
return Ok(response);
}
}
Expand Down
2 changes: 1 addition & 1 deletion workspace/twowaiyo/Cargo.toml
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
[package]
name = "twowaiyo"
version = "0.4.0"
version = "0.4.1"
edition = "2018"

[lib]
Expand Down

0 comments on commit 3297bdc

Please sign in to comment.