Skip to content

Commit

Permalink
remove redundant background task log entries (#6323)
Browse files Browse the repository at this point in the history
  • Loading branch information
davepacheco authored Aug 16, 2024
1 parent a7885d1 commit 921ec6d
Show file tree
Hide file tree
Showing 7 changed files with 1 addition and 33 deletions.
3 changes: 0 additions & 3 deletions nexus/src/app/background/tasks/lookup_region_port.rs
Original file line number Diff line number Diff line change
Expand Up @@ -53,7 +53,6 @@ impl BackgroundTask for LookupRegionPort {
) -> BoxFuture<'a, serde_json::Value> {
async {
let log = &opctx.log;
info!(&log, "lookup region port task started");

let mut status = LookupRegionPortStatus::default();

Expand Down Expand Up @@ -147,8 +146,6 @@ impl BackgroundTask for LookupRegionPort {
}
}

info!(&log, "lookup region port task done");

json!(status)
}
.boxed()
Expand Down
4 changes: 1 addition & 3 deletions nexus/src/app/background/tasks/phantom_disks.rs
Original file line number Diff line number Diff line change
Expand Up @@ -43,7 +43,6 @@ impl BackgroundTask for PhantomDiskDetector {
) -> BoxFuture<'a, serde_json::Value> {
async {
let log = &opctx.log;
warn!(&log, "phantom disk task started");

let phantom_disks = match self.datastore.find_phantom_disks().await
{
Expand Down Expand Up @@ -83,14 +82,13 @@ impl BackgroundTask for PhantomDiskDetector {
} else {
info!(
&log,
"phandom disk {} un-deleted andset to faulted ok",
"phandom disk {} un-deleted and set to faulted ok",
disk.id(),
);
phantom_disk_deleted_ok += 1;
}
}

warn!(&log, "phantom disk task done");
json!({
"phantom_disk_deleted_ok": phantom_disk_deleted_ok,
"phantom_disk_deleted_err": phantom_disk_deleted_err,
Expand Down
3 changes: 0 additions & 3 deletions nexus/src/app/background/tasks/physical_disk_adoption.rs
Original file line number Diff line number Diff line change
Expand Up @@ -96,8 +96,6 @@ impl BackgroundTask for PhysicalDiskAdoption {
}

let mut disks_added = 0;
let log = &opctx.log;
warn!(&log, "physical disk adoption task started");

let collection_id = *self.rx_inventory_collection.borrow();
let Some(collection_id) = collection_id else {
Expand Down Expand Up @@ -171,7 +169,6 @@ impl BackgroundTask for PhysicalDiskAdoption {
);
}

warn!(&log, "physical disk adoption task done");
json!({
"physical_disks_added": disks_added,
})
Expand Down
3 changes: 0 additions & 3 deletions nexus/src/app/background/tasks/region_replacement.rs
Original file line number Diff line number Diff line change
Expand Up @@ -61,7 +61,6 @@ impl BackgroundTask for RegionReplacementDetector {
) -> BoxFuture<'a, serde_json::Value> {
async {
let log = &opctx.log;
warn!(&log, "region replacement task started");

let mut ok = 0;
let mut err = 0;
Expand Down Expand Up @@ -182,8 +181,6 @@ impl BackgroundTask for RegionReplacementDetector {
}
}

warn!(&log, "region replacement task done");

json!({
"region_replacement_started_ok": ok,
"region_replacement_started_err": err,
Expand Down
5 changes: 0 additions & 5 deletions nexus/src/app/background/tasks/region_replacement_driver.rs
Original file line number Diff line number Diff line change
Expand Up @@ -227,16 +227,11 @@ impl BackgroundTask for RegionReplacementDriver {
opctx: &'a OpContext,
) -> BoxFuture<'a, serde_json::Value> {
async {
let log = &opctx.log;
info!(&log, "region replacement driver task started");

let mut status = RegionReplacementDriverStatus::default();

self.drive_running_replacements_forward(opctx, &mut status).await;
self.complete_done_replacements(opctx, &mut status).await;

info!(&log, "region replacement driver task done");

json!(status)
}
.boxed()
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -129,12 +129,6 @@ impl BackgroundTask for RegionSnapshotReplacementGarbageCollect {
opctx: &'a OpContext,
) -> BoxFuture<'a, serde_json::Value> {
async move {
let log = &opctx.log;
info!(
&log,
"region snapshot replacement garbage collect task started",
);

let mut status =
RegionSnapshotReplacementGarbageCollectStatus::default();

Expand All @@ -144,11 +138,6 @@ impl BackgroundTask for RegionSnapshotReplacementGarbageCollect {
)
.await;

info!(
&log,
"region snapshot replacement garbage collect task done"
);

json!(status)
}
.boxed()
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -232,9 +232,6 @@ impl BackgroundTask for RegionSnapshotReplacementDetector {
opctx: &'a OpContext,
) -> BoxFuture<'a, serde_json::Value> {
async {
let log = &opctx.log;
info!(&log, "region snapshot replacement start task started");

let mut status = RegionSnapshotReplacementStartStatus::default();

self.create_requests_for_region_snapshots_on_expunged_disks(
Expand All @@ -249,8 +246,6 @@ impl BackgroundTask for RegionSnapshotReplacementDetector {
)
.await;

info!(&log, "region snapshot replacement start task done");

json!(status)
}
.boxed()
Expand Down

0 comments on commit 921ec6d

Please sign in to comment.