diff --git a/internal/a3m/a3m.go b/internal/a3m/a3m.go
index d53ced8f0..ef9685f8a 100644
--- a/internal/a3m/a3m.go
+++ b/internal/a3m/a3m.go
@@ -2,6 +2,7 @@ package a3m
 
 import (
 	context "context"
+	"database/sql"
 	"errors"
 	"fmt"
 	"time"
@@ -184,12 +185,15 @@ func savePreservationTasks(
 
 	for _, job := range jobs {
 		pt := datatypes.PreservationTask{
-			TaskID:               job.Id,
-			Name:                 job.Name,
-			Status:               jobStatusToPreservationTaskStatus[job.Status],
+			TaskID: job.Id,
+			Name:   job.Name,
+			Status: jobStatusToPreservationTaskStatus[job.Status],
+			StartedAt: sql.NullTime{
+				Time:  job.StartTime.AsTime(),
+				Valid: true,
+			},
 			PreservationActionID: paID,
 		}
-		pt.StartedAt.Time = job.StartTime.AsTime()
 		err := pkgsvc.CreatePreservationTask(ctx, &pt)
 		if err != nil {
 			telemetry.RecordError(span, err)
diff --git a/internal/a3m/a3m_test.go b/internal/a3m/a3m_test.go
index 4471f5622..ec7dd545a 100644
--- a/internal/a3m/a3m_test.go
+++ b/internal/a3m/a3m_test.go
@@ -69,7 +69,7 @@ func TestCreateAIPActivity(t *testing.T) {
 		Status: enums.PreservationTaskStatusDone,
 		StartedAt: sql.NullTime{
 			Time:  time.Date(2009, time.November, 10, 23, 0, 0, 0, time.UTC),
-			Valid: false,
+			Valid: true,
 		},
 	})