feat: support ops async job

Author: gitmkn

tencentcloud/provider.go

@@ -1161,6 +1161,7 @@ func Provider() *schema.Provider {
 			"tencentcloud_wedata_rule_templates":                                 wedata.DataSourceTencentCloudWedataRuleTemplates(),
 			"tencentcloud_wedata_ops_workflows":                                  wedata.DataSourceTencentCloudWedataOpsWorkflows(),
 			"tencentcloud_wedata_ops_workflow":                                   wedata.DataSourceTencentCloudWedataOpsWorkflow(),
+			"tencentcloud_wedata_ops_async_job":                                  wedata.DataSourceTencentCloudWedataOpsAsyncJob(),
 			"tencentcloud_wedata_data_source_list":                               wedata.DataSourceTencentCloudWedataDataSourceList(),
 			"tencentcloud_private_dns_records":                                   privatedns.DataSourceTencentCloudPrivateDnsRecords(),
 			"tencentcloud_private_dns_private_zone_list":                         privatedns.DataSourceTencentCloudPrivateDnsPrivateZoneList(),

tencentcloud/services/wedata/data_source_tc_wedata_ops_async_job.go

@@ -0,0 +1,10 @@
+Use this data source to query detailed information of wedata ops workflow
+
+Example Usage
+
+```hcl
+data "tencentcloud_wedata_ops_async_job" "wedata_ops_async_job" {
+    project_id = "2905622749543821312"
+    async_id = "20250929164443669"
+}
+```

tencentcloud/services/wedata/data_source_tc_wedata_ops_async_job.md

@@ -0,0 +1 @@
+package wedata

tencentcloud/services/wedata/data_source_tc_wedata_ops_async_job_extension.go

@@ -0,0 +1,32 @@
+package wedata_test
+
+import (
+	"testing"
+
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/resource"
+	tcacctest "github.com/tencentcloudstack/terraform-provider-tencentcloud/tencentcloud/acctest"
+)
+
+func TestAccTencentCloudWedataOpsAsyncJobDataSource_basic(t *testing.T) {
+	t.Parallel()
+	resource.Test(t, resource.TestCase{
+		PreCheck: func() {
+			tcacctest.AccPreCheck(t)
+		},
+		Providers: tcacctest.AccProviders,
+		Steps: []resource.TestStep{
+			{
+				Config: testAccWedataOpsAsyncJobDataSource,
+				Check: resource.ComposeTestCheckFunc(
+					tcacctest.AccCheckTencentCloudDataSourceID("data.tencentcloud_wedata_ops_async_job.wedata_ops_async_job"),
+				),
+			},
+		},
+	})
+}
+
+const testAccWedataOpsAsyncJobDataSource = `
+
+data "tencentcloud_wedata_ops_async_job" "wedata_ops_async_job" {
+}
+`

tencentcloud/services/wedata/data_source_tc_wedata_ops_async_job_test.go

@@ -232,6 +232,44 @@ func (me *WedataService) DescribeWedataOpsWorkflowByFilter(ctx context.Context,
 	return
 }
 
+func (me *WedataService) DescribeWedataOpsAsyncJobByFilter(ctx context.Context, param map[string]interface{}) (ret *wedatav20250806.GetOpsAsyncJobResponseParams, errRet error) {
+	var (
+		logId   = tccommon.GetLogId(ctx)
+		request = wedatav20250806.NewGetOpsAsyncJobRequest()
+	)
+
+	defer func() {
+		if errRet != nil {
+			log.Printf("[CRITAL]%s api[%s] fail, request body [%s], reason[%s]\n", logId, request.GetAction(), request.ToJsonString(), errRet.Error())
+		}
+	}()
+
+	for k, v := range param {
+		if k == "ProjectId" {
+			request.ProjectId = v.(*string)
+		}
+		if k == "AsyncId" {
+			request.AsyncId = v.(*string)
+		}
+	}
+
+	ratelimit.Check(request.GetAction())
+
+	response, err := me.client.UseWedataV20250806Client().GetOpsAsyncJob(request)
+	if err != nil {
+		errRet = err
+		return
+	}
+	log.Printf("[DEBUG]%s api[%s] success, request body [%s], response body [%s]\n", logId, request.GetAction(), request.ToJsonString(), response.ToJsonString())
+
+	if response == nil || response.Response == nil {
+		return
+	}
+
+	ret = response.Response
+	return
+}
+
 func (me *WedataService) DescribeWedataDataSourceListByFilter(ctx context.Context, param map[string]interface{}) (dataSourceList []*wedata.DataSourceInfo, errRet error) {
 	var (
 		logId   = tccommon.GetLogId(ctx)