推理节点新增数据调度功能

sdks/pcmscheduler/models.go

@@ -84,7 +84,7 @@ const (
 
 	BlockChainJobCreatePrefix = "job_create_"
 
-	Finish = "Finish"
+	Complete = "Complete"
 
 	NodeTypeBinding    = "binding"
 	NodeTypeUpload     = "upload"

sdks/scheduler/models.go

@@ -71,6 +71,7 @@ var JobInfoTypeUnion = types.NewTypeUnion[JobInfo](
 	(*BindingJobInfo)(nil),
 	(*PCMInferenceJobInfo)(nil),
 	(*CompleteJobInfo)(nil),
+	(*StartJobInfo)(nil),
 )
 var _ = serder.UseTypeUnionInternallyTagged(&JobInfoTypeUnion, "type")
 
@@ -150,7 +151,13 @@ type AIJobInfo struct {
 }
 
 type CompleteJobInfo struct {
-	serder.Metadata `union:"Finish"`
+	serder.Metadata `union:"Complete"`
+	JobInfoBase
+	Type string `json:"type"`
+}
+
+type StartJobInfo struct {
+	serder.Metadata `union:"Start"`
 	JobInfoBase
 	Type string `json:"type"`
 }