Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Stop replication task before applying changes that require the task to be stopped. #24047

Merged
merged 15 commits into from
Apr 26, 2022
Merged

Stop replication task before applying changes that require the task to be stopped. #24047

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
15 commits
Select commit Hold shift + click to select a range
de8b9cb
Fix replication task lifecycle.
fermezz Apr 6, 2022
b72e4b1
Clean up debug logging
fermezz Apr 6, 2022
3fe3cb5
Fix
fermezz Apr 6, 2022
befba7e
tabs vs spaces i hate go
fermezz Apr 6, 2022
0cc6828
Add changelog
fermezz Apr 6, 2022
8717eac
Fix acc test
fermezz Apr 6, 2022
e73eaab
extra import
fermezz Apr 6, 2022
bab949d
Simplify changelog
fermezz Apr 7, 2022
68e5278
Merge branch 'main' into fix-start-replication-task
johnsonaj Apr 26, 2022
330942a
r/aws_replication_task: acctest fmt
johnsonaj Apr 26, 2022
ad14c8e
r/aws_replication_task: rearrage test steps
johnsonaj Apr 26, 2022
fa738a5
r/aws_replication_task: check task status using find results
johnsonaj Apr 26, 2022
59532f5
r/aws_replication_task: increase waiter delay for stopping task
johnsonaj Apr 26, 2022
ee1c669
update release note
johnsonaj Apr 26, 2022
824cb0c
r/aws_replication_task: add _disappears test
johnsonaj Apr 26, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 3 additions & 0 deletions .changelog/24047.txt
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,3 @@
```release-note:bug
resource/aws_dms_replication_task: Fix to stop the task before updating, if required
```
23 changes: 18 additions & 5 deletions internal/service/dms/replication_task.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -253,8 +253,15 @@ func resourceReplicationTaskUpdate(d *schema.ResourceData, meta interface{}) err
input.TableMappings = aws.String(d.Get("table_mappings").(string))
}

log.Println("[DEBUG] DMS update replication task:", input)
status := d.Get("status").(string)
if status == replicationTaskStatusRunning {
log.Println("[DEBUG] stopping DMS replication task:", input)
if err := stopReplicationTask(d.Id(), conn); err != nil {
return err
}
}

log.Println("[DEBUG] updating DMS replication task:", input)
_, err := conn.ModifyReplicationTask(input)
if err != nil {
return fmt.Errorf("error updating DMS Replication Task (%s): %w", d.Id(), err)
Expand All @@ -265,7 +272,8 @@ func resourceReplicationTaskUpdate(d *schema.ResourceData, meta interface{}) err
}

if d.Get("start_replication_task").(bool) {
if err := startReplicationTask(d.Id(), conn); err != nil {
err := startReplicationTask(d.Id(), conn)
if err != nil {
return err
}
}
Expand Down Expand Up @@ -373,9 +381,14 @@ func startReplicationTask(id string, conn *dms.DatabaseMigrationService) error {
return fmt.Errorf("error reading DMS Replication Task (%s): empty output", id)
}

startReplicationTaskType := dms.StartReplicationTaskTypeValueStartReplication
if aws.StringValue(task.Status) != replicationTaskStatusReady {
startReplicationTaskType = dms.StartReplicationTaskTypeValueResumeProcessing
}

_, err = conn.StartReplicationTask(&dms.StartReplicationTaskInput{
ReplicationTaskArn: task.ReplicationTaskArn,
StartReplicationTaskType: aws.String(dms.StartReplicationTaskTypeValueStartReplication),
StartReplicationTaskType: aws.String(startReplicationTaskType),
})

if err != nil {
Expand All @@ -384,7 +397,7 @@ func startReplicationTask(id string, conn *dms.DatabaseMigrationService) error {

err = waitReplicationTaskRunning(conn, id)
if err != nil {
return fmt.Errorf("error wating for DMS Replication Task (%s) start: %w", id, err)
return fmt.Errorf("error waiting for DMS Replication Task (%s) start: %w", id, err)
}

return nil
Expand Down Expand Up @@ -412,7 +425,7 @@ func stopReplicationTask(id string, conn *dms.DatabaseMigrationService) error {

err = waitReplicationTaskStopped(conn, id)
if err != nil {
return fmt.Errorf("error wating for DMS Replication Task (%s) stop: %w", id, err)
return fmt.Errorf("error waiting for DMS Replication Task (%s) stop: %w", id, err)
}

return nil
Expand Down
Loading