r/dms_replication_task: set cdc_start_position to computed

.changelog/23328.txt

@@ -0,0 +1,3 @@
+```release-note:bug
+resource/aws_dms_replication_task: Allow `cdc_start_position` to be computed
+```

internal/service/dms/consts.go

@@ -2,6 +2,13 @@ package dms
 
 const (
 	endpointStatusDeleting = "deleting"
+
+	replicationTaskStatusCreating  = "creating"
+	replicationTaskStatusDeleting  = "deleting"
+	replicationTaskStatusFailed    = "failed"
+	replicationTaskStatusModifying = "modifying"
+	replicationTaskStatusReady     = "ready"
+	replicationTaskStatusStopped   = "stopped"
 )
 
 const (

internal/service/dms/find.go

@@ -41,3 +41,52 @@ func FindEndpointByID(conn *dms.DatabaseMigrationService, id string) (*dms.Endpo
 
 	return output.Endpoints[0], nil
 }
+
+func FindReplicationTaskByID(conn *dms.DatabaseMigrationService, id string) (*dms.ReplicationTask, error) {
+	input := &dms.DescribeReplicationTasksInput{
+		Filters: []*dms.Filter{
+			{
+				Name:   aws.String("replication-task-id"),
+				Values: []*string{aws.String(id)}, // Must use d.Id() to work with import.
+			},
+		},
+	}
+
+	var results []*dms.ReplicationTask
+
+	err := conn.DescribeReplicationTasksPages(input, func(page *dms.DescribeReplicationTasksOutput, lastPage bool) bool {
+		if page == nil {
+			return !lastPage
+		}
+
+		for _, task := range page.ReplicationTasks {
+			if task == nil {
+				continue
+			}
+			results = append(results, task)
+		}
+
+		return !lastPage
+	})
+
+	if tfawserr.ErrCodeEquals(err, dms.ErrCodeResourceNotFoundFault) {
+		return nil, &resource.NotFoundError{
+			LastError:   err,
+			LastRequest: input,
+		}
+	}
+
+	if err != nil {
+		return nil, err
+	}
+
+	if len(results) == 0 {
+		return nil, tfresource.NewEmptyResultError(input)
+	}
+
+	if count := len(results); count > 1 {
+		return nil, tfresource.NewTooManyResultsError(count, input)
+	}
+
+	return results[0], nil
+}