Skip to content

Commit

Permalink
Get current context in alpenrose
Browse files Browse the repository at this point in the history
  • Loading branch information
kylerchin committed Apr 24, 2024
1 parent 801894d commit 7892327
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 2 deletions.
2 changes: 1 addition & 1 deletion src/alpenrose/single_fetch_time.rs
Original file line number Diff line number Diff line change
Expand Up @@ -108,7 +108,7 @@ pub async fn single_fetch_time(
);
let socket_addr = std::net::SocketAddr::new(data.tailscale_ip, 40427);

let mut transport =
let transport =
tarpc::serde_transport::tcp::connect(socket_addr, Bincode::default)
.await
.unwrap();
Expand Down
4 changes: 3 additions & 1 deletion src/aspen/import_alpenrose.rs
Original file line number Diff line number Diff line change
Expand Up @@ -52,7 +52,9 @@ pub async fn new_rt_data(
let conn_pool = pool.as_ref();
let conn_pre = conn_pool.get().await;

println!("Forming pg connection");
let conn = &mut conn_pre?;
println!("Connected to postges");

let vehicles_gtfs_rt = match vehicles_response_code {
Some(200) => match vehicles {
Expand Down Expand Up @@ -123,7 +125,7 @@ pub async fn new_rt_data(

//if this item is empty, create it
if this_chateau_dashmap.is_none() {
let mut new_aspenised_data = catenary::aspen_dataset::AspenisedData {
let new_aspenised_data = catenary::aspen_dataset::AspenisedData {
vehicle_positions: HashMap::new(),
vehicle_routes_cache: HashMap::new(),
trip_updates: HashMap::new(),
Expand Down

0 comments on commit 7892327

Please sign in to comment.