feat: support ops workflow

Author: gitmkn

tencentcloud/provider.go

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

tencentcloud/provider.md

@@ -2221,6 +2221,7 @@ Wedata
 Data Source
 tencentcloud_wedata_rule_templates
 tencentcloud_wedata_ops_workflows
+tencentcloud_wedata_ops_workflow
 tencentcloud_wedata_data_source_list
 
 Resource

tencentcloud/services/wedata/data_source_tc_wedata_ops_workflow.go

@@ -0,0 +1,10 @@
+Use this data source to query detailed information of wedata ops workflow
+
+Example Usage
+
+```hcl
+data "tencentcloud_wedata_ops_workflow" "wedata_ops_workflow" {
+    project_id = "2905622749543821312"
+    workflow_id = "Cycle"
+}
+```

tencentcloud/services/wedata/data_source_tc_wedata_ops_workflow.md

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

tencentcloud/services/wedata/data_source_tc_wedata_ops_workflow_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 TestAccTencentCloudWedataOpsWorkflowDataSource_basic(t *testing.T) {
+	t.Parallel()
+	resource.Test(t, resource.TestCase{
+		PreCheck: func() {
+			tcacctest.AccPreCheck(t)
+		},
+		Providers: tcacctest.AccProviders,
+		Steps: []resource.TestStep{
+			{
+				Config: testAccWedataOpsWorkflowDataSource,
+				Check: resource.ComposeTestCheckFunc(
+					tcacctest.AccCheckTencentCloudDataSourceID("data.tencentcloud_wedata_ops_workflow.wedata_ops_workflow"),
+				),
+			},
+		},
+	})
+}
+
+const testAccWedataOpsWorkflowDataSource = `
+
+data "tencentcloud_wedata_ops_workflow" "wedata_ops_workflow" {
+}
+`

tencentcloud/services/wedata/data_source_tc_wedata_ops_workflow_test.go

@@ -18,7 +18,7 @@ func TestAccTencentCloudWedataOpsWorkflowsDataSource_basic(t *testing.T) {
 			{
 				Config: testAccWedataOpsWorkflowsDataSource,
 				Check: resource.ComposeTestCheckFunc(
-					tcacctest.AccCheckTencentCloudDataSourceID("data.tencentcloud_wedata_rule_templates.rule_templates"),
+					tcacctest.AccCheckTencentCloudDataSourceID("data.tencentcloud_wedata_ops_workflows.wedata_ops_workflows"),
 				),
 			},
 		},

tencentcloud/services/wedata/data_source_tc_wedata_ops_workflows_test.go

@@ -194,6 +194,44 @@ func (me *WedataService) DescribeWedataOpsWorkflowsByFilter(ctx context.Context,
 	return
 }
 
+func (me *WedataService) DescribeWedataOpsWorkflowByFilter(ctx context.Context, param map[string]interface{}) (ret *wedatav20250806.GetOpsWorkflowResponseParams, errRet error) {
+	var (
+		logId   = tccommon.GetLogId(ctx)
+		request = wedatav20250806.NewGetOpsWorkflowRequest()
+	)
+
+	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 == "WorkflowId" {
+			request.WorkflowId = v.(*string)
+		}
+	}
+
+	ratelimit.Check(request.GetAction())
+
+	response, err := me.client.UseWedataV20250806Client().GetOpsWorkflow(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)