test(core): wait for cron persistence before cleanup

core/management_test.go

@@ -632,6 +632,9 @@ func TestMgmt_CronExecByID(t *testing.T) {
 	if len(platform.getSent()) < 2 {
 		t.Fatalf("timed out waiting for triggered cron exec, sent=%v", platform.getSent())
 	}
+	// A platform reply precedes runJob's final MarkRun save. Wait for that
+	// write before TempDir cleanup can remove the cron store directory.
+	waitForCronRunPersisted(t, store.path, job.ID)
 
 	aliasJob := &CronJob{
 		ID:          "cron-run-alias-1",
@@ -656,6 +659,7 @@ func TestMgmt_CronExecByID(t *testing.T) {
 	deadline = time.Now().Add(2 * time.Second)
 	for time.Now().Before(deadline) {
 		if len(platform.getSent()) >= 4 {
+			waitForCronRunPersisted(t, store.path, aliasJob.ID)
 			return
 		}
 		time.Sleep(10 * time.Millisecond)
@@ -663,6 +667,26 @@ func TestMgmt_CronExecByID(t *testing.T) {
 	t.Fatalf("timed out waiting for triggered cron run alias, sent=%v", platform.getSent())
 }
 
+func waitForCronRunPersisted(t *testing.T, path, id string) {
+	t.Helper()
+	deadline := time.Now().Add(2 * time.Second)
+	for time.Now().Before(deadline) {
+		data, err := os.ReadFile(path)
+		if err == nil {
+			var jobs []CronJob
+			if json.Unmarshal(data, &jobs) == nil {
+				for _, job := range jobs {
+					if job.ID == id && !job.LastRun.IsZero() {
+						return
+					}
+				}
+			}
+		}
+		time.Sleep(10 * time.Millisecond)
+	}
+	t.Fatalf("timed out waiting for cron run %q to be persisted", id)
+}
+
 func TestMgmt_CronExecByID_RejectsExtraPathSegments(t *testing.T) {
 	mgmt, ts, e := testManagementServer(t, "tok")
 	store, err := NewCronStore(t.TempDir())