删除queue id

tencentyun · Aug 1, 2023 · f019b7c · f019b7c
1 parent ffa9ed3
commit f019b7c
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 6 deletions.
diff --git a/example/CI/workflow_and_job/inventory.go b/example/CI/workflow_and_job/inventory.go
@@ -146,7 +146,6 @@ func CreateInventoryTriggerJobByParam() {
 		},
 		Type: "Job",
 		Operation: &cos.InventoryTriggerJobOperation{
-			QueueId: "pa27b2bd96bef43b6baba820175485532",
 			TimeInterval: cos.InventoryTriggerJobOperationTimeInterval{
 				Start: "2002-02-16T10:45:12+0800",
 				End:   "2023-05-16T10:45:12+0800",

diff --git a/example/CI/workflow_and_job/jobs.go b/example/CI/workflow_and_job/jobs.go
@@ -64,7 +64,6 @@ func CancelJob() {
 func DescribeJobs() {
 	c := getClient()
 	opt := &cos.DescribeJobsOptions{
-		QueueId: "pa27b2bd96bef43b6baba820175485532",
 		Tag:     "Transcode",
 	}
 	DescribeJobRes, _, err := c.CI.DescribeJobs(context.Background(), opt)

diff --git a/example/CI/workflow_and_job/workflow.go b/example/CI/workflow_and_job/workflow.go
@@ -90,7 +90,7 @@ func CreateWorkflow() {
 			Topology: &cos.Topology{
 				Dependencies: map[string]string{"Start": "Transcode_1581665960537", "Transcode_1581665960537": "Snapshot_1581665960536",
 					"Snapshot_1581665960536": "End"},
-				Nodes: map[string]cos.Node{"Start": cos.Node{Type: "Start", Input: &cos.NodeInput{QueueId: "p09d709939fef48a0a5c247ef39d90cec",
+				Nodes: map[string]cos.Node{"Start": cos.Node{Type: "Start", Input: &cos.NodeInput{
 					ObjectPrefix: "wk-test", ExtFilter: &cos.ExtFilter{State: "On", Custom: "true", CustomExts: "mp4"}}},
 					"Transcode_1581665960537": cos.Node{Type: "Transcode", Operation: &cos.NodeOperation{TemplateId: "t01e57db1c2d154d2fb57aa5de9313a897",
 						Output: &cos.NodeOutput{Region: "ap-chongqing", Bucket: "test-123456789", Object: "trans1.mp4"}}},
@@ -117,7 +117,7 @@ func UpdateWorkflow() {
 			Topology: &cos.Topology{
 				Dependencies: map[string]string{"Start": "Transcode_1581665960537", "Transcode_1581665960537": "Snapshot_1581665960536",
 					"Snapshot_1581665960536": "End"},
-				Nodes: map[string]cos.Node{"Start": cos.Node{Type: "Start", Input: &cos.NodeInput{QueueId: "p09d709939fef48a0a5c247ef39d90cec",
+				Nodes: map[string]cos.Node{"Start": cos.Node{Type: "Start", Input: &cos.NodeInput{
 					ObjectPrefix: "wk-test", ExtFilter: &cos.ExtFilter{State: "On", Custom: "true", CustomExts: "mp4"}}},
 					"Transcode_1581665960537": cos.Node{Type: "Transcode", Operation: &cos.NodeOperation{TemplateId: "t01e57db1c2d154d2fb57aa5de9313a897",
 						Output: &cos.NodeOutput{Region: "ap-chongqing", Bucket: "test-123456789", Object: "trans1.mp4"}}},
@@ -158,7 +158,7 @@ func CreateStreamWorkflow() {
 				Dependencies: map[string]string{"Start": "StreamPackConfig_1581665960532", "StreamPackConfig_1581665960532": "VideoStream_1581665960536,VideoStream_1581665960537",
 					"VideoStream_1581665960536": "StreamPack_1581665960538", "VideoStream_1581665960537": "StreamPack_1581665960538",
 					"StreamPack_1581665960538": "End"},
-				Nodes: map[string]cos.Node{"Start": cos.Node{Type: "Start", Input: &cos.NodeInput{QueueId: "p09d709939fef48a0a5c247ef39d90cec",
+				Nodes: map[string]cos.Node{"Start": cos.Node{Type: "Start", Input: &cos.NodeInput{
 					ObjectPrefix: "wk-test", ExtFilter: &cos.ExtFilter{State: "On", Custom: "true", CustomExts: "mp4"}}},
 					"StreamPackConfig_1581665960532": cos.Node{Type: "StreamPackConfig", Operation: &cos.NodeOperation{
 						Output:               &cos.NodeOutput{Region: "ap-chongqing", Bucket: "test-123456789", Object: "${InputPath}/${InputName}._${RunId}.${ext}"},
@@ -195,7 +195,7 @@ func UpdatStreamWorkflow() {
 				Dependencies: map[string]string{"Start": "StreamPackConfig_1581665960532", "StreamPackConfig_1581665960532": "VideoStream_1581665960536,VideoStream_1581665960537",
 					"VideoStream_1581665960536": "StreamPack_1581665960538", "VideoStream_1581665960537": "StreamPack_1581665960538",
 					"StreamPack_1581665960538": "End"},
-				Nodes: map[string]cos.Node{"Start": cos.Node{Type: "Start", Input: &cos.NodeInput{QueueId: "p09d709939fef48a0a5c247ef39d90cec",
+				Nodes: map[string]cos.Node{"Start": cos.Node{Type: "Start", Input: &cos.NodeInput{
 					ObjectPrefix: "wk-test", ExtFilter: &cos.ExtFilter{State: "On", Custom: "true", CustomExts: "mp4"}}},
 					"StreamPackConfig_1581665960532": cos.Node{Type: "StreamPackConfig", Operation: &cos.NodeOperation{
 						Output:               &cos.NodeOutput{Region: "ap-chongqing", Bucket: "test-123456789", Object: "${InputPath}/${InputName}._${RunId}.${ext}"},