Skip to content

Commit

Permalink
upgrade redis and openai, bump version
Browse files Browse the repository at this point in the history
  • Loading branch information
snowmead committed May 15, 2024
1 parent b7aa32e commit ae3aced
Show file tree
Hide file tree
Showing 4 changed files with 29 additions and 126 deletions.
139 changes: 22 additions & 117 deletions Cargo.lock

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

6 changes: 3 additions & 3 deletions Cargo.toml
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
[package]
publish = true
name = "llm-weaver"
version = "0.1.94"
version = "0.1.95"
edition = "2021"
description = "Manage long conversations with any LLM"
readme = "README.md"
Expand All @@ -20,12 +20,12 @@ exclude = [
]

[dependencies]
async-openai = "0.20.0"
async-openai = "0.21.0"
tokio = { version = "1.32.0", features = ["full"] }
tracing = "0.1.37"
serde_json = "1.0.107"
serde = { version = "1.0.188", features = ["derive"] }
redis = { version = "0.24.0", features = [
redis = { version = "0.25.0", features = [
"tokio-comp",
"tokio-rustls-comp",
"json",
Expand Down
2 changes: 0 additions & 2 deletions src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -523,8 +523,6 @@ pub trait Loom<T: Config> {
.ctx_msgs_to_prompt_requests(tapestry_fragment.context_messages.as_slice()),
);

println!("prompting summary model");

let res = summary_model_config
.model
.prompt(
Expand Down
8 changes: 4 additions & 4 deletions src/storage.rs
Original file line number Diff line number Diff line change
Expand Up @@ -159,7 +159,7 @@ impl<T: Config> TapestryChestHandler<T> for TapestryChest {
metadata: M,
) -> crate::Result<()> {
let client = get_client().await.expect("Failed to get redis client");
let mut con = client.get_async_connection().await?;
let mut con = client.get_multiplexed_async_connection().await?;
debug!("Connected to Redis");

let key: &String = &tapestry_id.base_key();
Expand All @@ -176,7 +176,7 @@ impl<T: Config> TapestryChestHandler<T> for TapestryChest {

async fn get_tapestry<TID: TapestryId>(tapestry_id: TID) -> crate::Result<Option<u16>> {
let client = get_client().await.expect("Failed to get redis client");
let mut con = client.get_async_connection().await?;
let mut con = client.get_multiplexed_async_connection().await?;

let base_key = &tapestry_id.base_key();

Expand Down Expand Up @@ -248,7 +248,7 @@ impl<T: Config> TapestryChestHandler<T> for TapestryChest {
tapestry_id: TID,
) -> crate::Result<Option<M>> {
let client = get_client().await.expect("Failed to get redis client");
let mut con = client.get_async_connection().await?;
let mut con = client.get_multiplexed_async_connection().await?;
debug!("Connected to Redis");

let key = &tapestry_id.base_key();
Expand All @@ -268,7 +268,7 @@ impl<T: Config> TapestryChestHandler<T> for TapestryChest {

async fn delete_tapestry<TID: TapestryId>(tapestry_id: TID) -> crate::Result<()> {
let client = get_client().await.expect("Failed to get redis client");
let mut con = client.get_async_connection().await?;
let mut con = client.get_multiplexed_async_connection().await?;

let tapestry_id = &tapestry_id.base_key();

Expand Down

0 comments on commit ae3aced

Please sign in to comment.