Skip to content

Commit

Permalink
chore: fix formatting
Browse files Browse the repository at this point in the history
  • Loading branch information
th7nder committed Nov 4, 2024
1 parent 55f0a92 commit 50a130a
Show file tree
Hide file tree
Showing 3 changed files with 7 additions and 6 deletions.
9 changes: 5 additions & 4 deletions cli/polka-storage-provider/server/src/pipeline/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -19,14 +19,13 @@ use tokio::{
task::{JoinError, JoinHandle},
};
use tokio_util::{sync::CancellationToken, task::TaskTracker};
use types::{AddPieceMessage, PipelineMessage, PreCommitMessage};

use self::types::Sector;
use crate::{
db::{DBError, DealDB},
pipeline::types::SectorState,
};
use types::{AddPieceMessage, PipelineMessage, PreCommitMessage};

use self::types::Sector;

// PLACEHOLDERS!!!!!
// TODO(@th7nder,29/10/2024): get from pallet randomness
Expand Down Expand Up @@ -133,7 +132,9 @@ fn process(
tracker.spawn(async move {
// Precommit is not cancellation safe.
match precommit(state, sector_id).await {
Ok(_) => tracing::info!("Precommit for sector {} finished successfully.", sector_id),
Ok(_) => {
tracing::info!("Precommit for sector {} finished successfully.", sector_id)
}
Err(err) => tracing::error!(%err),
}
});
Expand Down
3 changes: 2 additions & 1 deletion cli/polka-storage-provider/server/src/pipeline/types.rs
Original file line number Diff line number Diff line change
@@ -1,10 +1,11 @@
use std::path::PathBuf;

use primitives_commitment::{
piece::{PieceInfo, UnpaddedPieceSize},
Commitment,
};
use primitives_proofs::{DealId, SectorNumber};
use serde::{Deserialize, Serialize};
use std::path::PathBuf;
use storagext::types::market::DealProposal;

/// Represents a task to be executed on the Storage Provider Pipeline
Expand Down
1 change: 0 additions & 1 deletion cli/polka-storage-provider/server/src/rpc.rs
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,6 @@ use storagext::{
types::market::{ClientDealProposal as SxtClientDealProposal, DealProposal as SxtDealProposal},
MarketClientExt,
};

use tokio::sync::mpsc::UnboundedSender;
use tokio_util::sync::CancellationToken;
use tracing::{info, instrument};
Expand Down

0 comments on commit 50a130a

Please sign in to comment.