Skip to content

Commit

Permalink
fix(logs): Correctly extract proxy name
Browse files Browse the repository at this point in the history
  • Loading branch information
Threated authored and torbrenner committed Jun 20, 2024
1 parent af7aba8 commit af2ccd2
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion src/main.rs
Original file line number Diff line number Diff line change
Expand Up @@ -172,7 +172,7 @@ async fn handle_listen_to_beam_tasks(
async_sse::Event::Message(m) => {
if let Ok(result) = serde_json::from_slice::<TaskResult<beam_lib::RawString>>(m.data()) {
if result.status == beam_lib::WorkStatus::Succeeded {
sender.send(result.from.as_ref().split('.').nth(2).unwrap().to_owned()).await.expect("not dropped");
sender.send(result.from.as_ref().split('.').nth(1).unwrap().to_owned()).await.expect("not dropped");
}
}
Ok(Event::default().data(String::from_utf8_lossy(m.data())).event(m.name()))
Expand Down

0 comments on commit af2ccd2

Please sign in to comment.