Skip to content

S
scheduler
Commit 675678e9 authored by vicotor's avatar vicotor
Browse files
Options

update producer

parent b0dd2c62
Hide whitespace changes
Inline Side-by-side
Showing with 6 additions and 6 deletions
cmd/producer/producer.go
View file @ 675678e9
...@@ -78,17 +78,17 @@ func produceTask() { ...@@ -78,17 +78,17 @@ func produceTask() {
func makeTask() *odysseus.TaskContent { func makeTask() *odysseus.TaskContent {
task := &odysseus.TaskContent{ task := &odysseus.TaskContent{
TaskId: uuid.NewString(), TaskId: uuid.NewString(),
TaskType: 1, TaskType: 84,
TaskKind: odysseus.TaskKind_ComputeTask, TaskKind: odysseus.TaskKind_ComputeTask,
TaskCmd: "", TaskCmd: "{\"api_url\":\"/aigic\",\"docker_cmd\":{\"container_port\":8888},\"image_name\":\"xueqianlu/llm-test:v0.0.1\"}",
TaskParam: []byte("give me five"), TaskParam: []byte("{}"),
TaskTimestamp: uint64(time.Now().UnixNano() / 1000), TaskTimestamp: uint64(time.Now().UnixNano() / 1000),
TaskCallback: "http://localhost:8080/callback", TaskCallback: "http://localhost:8080/callback",
TaskUid: "1", TaskUid: "51",
TaskFee: "10", TaskFee: "0",
TaskInLen: 10, TaskInLen: 10,
TaskWorkload: 100, TaskWorkload: 100,
ContainerPubkey: []byte{}, ContainerPubkey: []byte("0423965c5d5b4c2fa03fe024cfbcd413db25e7c420b73bd5dccb78fada9e22d4848d32952c913ae0cdcc70efa38094dc49c05c6a0cec7e1712557050da7d7bd05a"),
} }
return task return task
} }
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment