fix(dts): pause sync job before isolation to prevent UnsupportedOperation on delete

The Delete function called IsolateSyncJobs directly on running jobs, which
Tencent rejects with UnsupportedOperation. Added a pre-isolation status check
that pauses the job first if it is still running, then proceeds with isolation.

Also fixed the Read function to return nil (not an error) when the job is not
found, allowing Terraform to remove stale state entries gracefully instead of
failing every subsequent plan.

Fixes: UnsupportedOperation.UnsupportedOperationError on destroy
Fixes: "resource syncJob sync-xxx does not exist" breaking plan after out-of-band deletion

Author: rladkat

tencentcloud/services/dts/resource_tc_dts_sync_job.go

@@ -2,7 +2,6 @@ package dts
 
 import (
 	"context"
-	"fmt"
 	"log"
 	"time"
 
@@ -238,7 +237,7 @@ func resourceTencentCloudDtsSyncJobRead(d *schema.ResourceData, meta interface{}
 
 	if syncJob == nil {
 		d.SetId("")
-		return fmt.Errorf("resource `syncJob` %s does not exist", syncJobId)
+		return nil
 	}
 
 	if syncJob.PayMode != nil {
@@ -311,6 +310,35 @@ func resourceTencentCloudDtsSyncJobDelete(d *schema.ResourceData, meta interface
 
 	syncJobId := d.Id()
 
+	// Check current state before attempting isolation.
+	syncJob, err := service.DescribeDtsSyncJob(ctx, helper.String(syncJobId))
+	if err != nil {
+		return err
+	}
+
+	// Job already gone — remove from state cleanly.
+	if syncJob == nil {
+		return nil
+	}
+
+	// Job already in a billing-terminal state (auto-deleted by Tencent) — nothing to do.
+	if syncJob.TradeStatus != nil && (*syncJob.TradeStatus == "NotBilledByInternational" || *syncJob.TradeStatus == "NotBilled") {
+		return nil
+	}
+
+	// Job is running or syncing — pause it first so isolation is accepted.
+	if syncJob.Status != nil && *syncJob.Status != "Paused" && *syncJob.Status != "Isolated" {
+		log.Printf("[DEBUG]%s sync job[%s] is in status [%s], pausing before isolation\n", logId, syncJobId, *syncJob.Status)
+		if err := service.PauseDtsSyncJobById(ctx, syncJobId); err != nil {
+			return err
+		}
+
+		conf := tccommon.BuildStateChangeConf([]string{}, []string{"Paused"}, 2*tccommon.ReadRetryTimeout, time.Second, service.DtsSyncJobStateRefreshFunc(syncJobId, "Paused", []string{}))
+		if _, e := conf.WaitForState(); e != nil {
+			return e
+		}
+	}
+
 	if err := service.IsolateDtsSyncJobById(ctx, syncJobId); err != nil {
 		return err
 	}

tencentcloud/services/dts/service_tencentcloud_dts.go

@@ -136,6 +136,31 @@ func (me *DtsService) DescribeDtsSyncJobsByFilter(ctx context.Context, param map
 	return
 }
 
+func (me *DtsService) PauseDtsSyncJobById(ctx context.Context, jobId string) (errRet error) {
+	logId := tccommon.GetLogId(ctx)
+
+	request := dts.NewPauseSyncJobRequest()
+	request.JobId = helper.String(jobId)
+
+	defer func() {
+		if errRet != nil {
+			log.Printf("[CRITAL]%s api[%s] fail, request body [%s], reason[%s]\n",
+				logId, "pause object", request.ToJsonString(), errRet.Error())
+		}
+	}()
+
+	ratelimit.Check(request.GetAction())
+	response, err := me.client.UseDtsClient().PauseSyncJob(request)
+	if err != nil {
+		errRet = err
+		return err
+	}
+	log.Printf("[DEBUG]%s api[%s] success, request body [%s], response body [%s]\n",
+		logId, request.GetAction(), request.ToJsonString(), response.ToJsonString())
+
+	return
+}
+
 func (me *DtsService) IsolateDtsSyncJobById(ctx context.Context, jobId string) (errRet error) {
 	logId := tccommon.GetLogId(ctx)