diff --git a/service/worker/scanner/executions/workflows.go b/service/worker/scanner/executions/workflows.go
index 3b272199b05..49a48f236dd 100644
--- a/service/worker/scanner/executions/workflows.go
+++ b/service/worker/scanner/executions/workflows.go
@@ -354,6 +354,7 @@ func ScannerWorkflow(
 		ShardControlFlowFailureCount: aggregator.statusSummary[ShardStatusControlFlowFailure],
 		AggregateReportResult:        aggregator.aggregation,
 		ShardDistributionStats:       aggregator.getShardDistributionStats(),
+		ScanType:                     params.ScanType,
 	}).Get(ctx, nil); err != nil {
 		return err
 	}
@@ -460,6 +461,7 @@ func getCorruptedKeys(
 		ScannerWorkflowWorkflowID: params.ScannerWorkflowWorkflowID,
 		ScannerWorkflowRunID:      params.ScannerWorkflowRunID,
 		StartingShardID:           nil,
+		ScanType:                  params.ScanType,
 	}
 	var minShardID *int
 	var maxShardID *int