feat: support wedata ops

Author: gitmkn

tencentcloud/provider.go

@@ -1167,8 +1167,9 @@ func Provider() *schema.Provider {
 			"tencentcloud_wedata_task_instances":                                 wedata.DataSourceTencentCloudWedataTaskInstances(),
 			"tencentcloud_wedata_task_instance_log":                              wedata.DataSourceTencentCloudWedataTaskInstanceLog(),
 			"tencentcloud_wedata_upstream_task_instances":                        wedata.DataSourceTencentCloudWedataUpstreamTaskInstances(),
-			"tencentcloud_wedata_downstream_task_instances":                      wedata.DataSourceTencentCloudWedataDownTaskInstances(),
+			"tencentcloud_wedata_downstream_task_instances":                      wedata.DataSourceTencentCloudWedataDownstreamTaskInstances(),
 			"tencentcloud_wedata_data_source_list":                               wedata.DataSourceTencentCloudWedataDataSourceList(),
+			"tencentcloud_wedata_task_instance_executions":                       wedata.DataSourceTencentCloudWedataTaskInstanceExecutions(),
 			"tencentcloud_private_dns_records":                                   privatedns.DataSourceTencentCloudPrivateDnsRecords(),
 			"tencentcloud_private_dns_private_zone_list":                         privatedns.DataSourceTencentCloudPrivateDnsPrivateZoneList(),
 			"tencentcloud_private_dns_forward_rules":                             privatedns.DataSourceTencentCloudPrivateDnsForwardRules(),

tencentcloud/services/wedata/data_source_tc_wedata_down_task_instances.go

@@ -7,7 +7,7 @@ import (
 	tcacctest "github.com/tencentcloudstack/terraform-provider-tencentcloud/tencentcloud/acctest"
 )
 
-func TestAccTencentCloudWedataDownTaskInstancesDataSource_basic(t *testing.T) {
+func TestAccTencentCloudWedataDownstreamTaskInstancesDataSource_basic(t *testing.T) {
 	t.Parallel()
 	resource.Test(t, resource.TestCase{
 		PreCheck: func() {
@@ -18,7 +18,10 @@ func TestAccTencentCloudWedataDownTaskInstancesDataSource_basic(t *testing.T) {
 			{
 				Config: testAccWedataDownTaskInstancesDataSource,
 				Check: resource.ComposeTestCheckFunc(
-					tcacctest.AccCheckTencentCloudDataSourceID("data.tencentcloud_wedata_down_task_instances.wedata_down_task_instances"),
+					tcacctest.AccCheckTencentCloudDataSourceID("data.tencentcloud_wedata_downstream_task_instances.wedata_down_task_instances"),
+					resource.TestCheckResourceAttrSet("data.tencentcloud_wedata_downstream_task_instances.wedata_down_task_instances", "id"),
+					resource.TestCheckResourceAttr("data.tencentcloud_wedata_downstream_task_instances.wedata_down_task_instances", "data.#", "1"),
+					resource.TestCheckResourceAttr("data.tencentcloud_wedata_downstream_task_instances.wedata_down_task_instances", "data.0.items.#", "1"),
 				),
 			},
 		},
@@ -27,6 +30,8 @@ func TestAccTencentCloudWedataDownTaskInstancesDataSource_basic(t *testing.T) {
 
 const testAccWedataDownTaskInstancesDataSource = `
 
-data "tencentcloud_wedata_down_task_instances" "wedata_down_task_instances" {
+data "tencentcloud_wedata_downstream_task_instances" "wedata_down_task_instances" {
+  project_id   = "1859317240494305280"
+  instance_key = "20250731151633120_2025-10-13 17:00:00"
 }
 `

tencentcloud/services/wedata/data_source_tc_wedata_down_task_instances_test.go

@@ -3,6 +3,8 @@ Use this data source to query detailed information of wedata downstream task ins
 Example Usage
 
 ```hcl
-data "tencentcloud_wedata_upstream_task_instances" "wedata_upstream_task_instances" {
+data "tencentcloud_wedata_downstream_task_instances" "wedata_down_task_instances" {
+  project_id   = "1859317240494305280"
+  instance_key = "20250731151633120_2025-10-13 17:00:00"
 }
 ```

tencentcloud/services/wedata/data_source_tc_wedata_downstream_task_instances.md

@@ -4,5 +4,6 @@ Example Usage
 
 ```hcl
 data "tencentcloud_wedata_ops_alarm_rules" "wedata_ops_alarm_rules" {
+  project_id = "1859317240494305280"
 }
 ```

tencentcloud/services/wedata/data_source_tc_wedata_ops_alarm_rules.go

@@ -19,6 +19,9 @@ func TestAccTencentCloudWedataOpsAlarmRulesDataSource_basic(t *testing.T) {
 				Config: testAccWedataOpsAlarmRulesDataSource,
 				Check: resource.ComposeTestCheckFunc(
 					tcacctest.AccCheckTencentCloudDataSourceID("data.tencentcloud_wedata_ops_alarm_rules.wedata_ops_alarm_rules"),
+					resource.TestCheckResourceAttrSet("data.tencentcloud_wedata_ops_alarm_rules.wedata_ops_alarm_rules", "id"),
+					resource.TestCheckResourceAttr("data.tencentcloud_wedata_ops_alarm_rules.wedata_ops_alarm_rules", "data.#", "1"),
+					resource.TestCheckResourceAttr("data.tencentcloud_wedata_ops_alarm_rules.wedata_ops_alarm_rules", "data.0.items.#", "20"),
 				),
 			},
 		},
@@ -28,5 +31,6 @@ func TestAccTencentCloudWedataOpsAlarmRulesDataSource_basic(t *testing.T) {
 const testAccWedataOpsAlarmRulesDataSource = `
 
 data "tencentcloud_wedata_ops_alarm_rules" "wedata_ops_alarm_rules" {
+  project_id = "1859317240494305280"
 }
 `

tencentcloud/services/wedata/data_source_tc_wedata_ops_alarm_rules.md

@@ -4,7 +4,7 @@ Example Usage
 
 ```hcl
 data "tencentcloud_wedata_ops_async_job" "wedata_ops_async_job" {
-    project_id = "2905622749543821312"
-    async_id = "20250929164443669"
+    project_id = "1859317240494305280"
+    async_id = "9ba294ff-46d9-4a77-ae4a-acd0b4bdca3c"
 }
 ```

tencentcloud/services/wedata/data_source_tc_wedata_ops_alarm_rules_test.go

@@ -19,6 +19,8 @@ func TestAccTencentCloudWedataOpsAsyncJobDataSource_basic(t *testing.T) {
 				Config: testAccWedataOpsAsyncJobDataSource,
 				Check: resource.ComposeTestCheckFunc(
 					tcacctest.AccCheckTencentCloudDataSourceID("data.tencentcloud_wedata_ops_async_job.wedata_ops_async_job"),
+					resource.TestCheckResourceAttrSet("data.tencentcloud_wedata_ops_async_job.wedata_ops_async_job", "id"),
+					resource.TestCheckResourceAttr("data.tencentcloud_wedata_ops_async_job.wedata_ops_async_job", "data.#", "1"),
 				),
 			},
 		},
@@ -28,5 +30,7 @@ func TestAccTencentCloudWedataOpsAsyncJobDataSource_basic(t *testing.T) {
 const testAccWedataOpsAsyncJobDataSource = `
 
 data "tencentcloud_wedata_ops_async_job" "wedata_ops_async_job" {
+    project_id = "1859317240494305280"
+    async_id = "9ba294ff-46d9-4a77-ae4a-acd0b4bdca3c"
 }
 `