Skip to content

Commit

Permalink
refac requested changes
Browse files Browse the repository at this point in the history
  • Loading branch information
lemosep committed Jun 14, 2024
1 parent 449f407 commit 14c6625
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 6 deletions.
6 changes: 3 additions & 3 deletions proto/src/worker/runner.rs
Original file line number Diff line number Diff line change
Expand Up @@ -12,17 +12,17 @@ use crate::common::instance::{InstanceId, InstanceSpec};
/// Starts a new deploy in the system
#[derive(Debug, Serialize, Deserialize)]
pub struct DeployInstanceReq {
pub id: DeoployReqId,
pub id: DeployReqId,
pub instance_spec: InstanceSpec,
}

#[derive(Debug, Serialize, Deserialize)]
pub struct DeployInstanceRes {
pub id: DeoployReqId,
pub id: DeployReqId,
}

#[derive(Debug, Serialize, Deserialize)]
pub struct DeoployReqId(Uuid);
pub struct DeployReqId(Uuid);

/// Starts a new deploy in the system.
#[derive(Debug, Serialize, Deserialize)]
Expand Down
5 changes: 2 additions & 3 deletions worker/src/main.rs
Original file line number Diff line number Diff line change
Expand Up @@ -16,13 +16,12 @@ mod runner;
async fn main() -> Result<()> {
setup::tracing();

let args = Arc::new(WorkerArgs::parse());
let args = WorkerArgs::parse();
info!(?args, "started worker");

let pusher_handle = tokio::spawn({
let args = Arc::clone(&args);
async move {
pusher::start_pusher(args).await;
pusher::start_pusher(Arc::new(args)).await;
}
});

Expand Down

0 comments on commit 14c6625

Please sign in to comment.