Updated all references to task queue: - cmd/worker/main.go: NewWorker second param - cmd/starter/main.go: ExecuteWorkflow StartWorkflowOptions + output display
This commit is contained in:
+2
-2
@@ -88,7 +88,7 @@ func main() {
|
|||||||
workflowID := "orch-" + strings.ReplaceAll(*repoPath, "/", "-")
|
workflowID := "orch-" + strings.ReplaceAll(*repoPath, "/", "-")
|
||||||
run, err := c.ExecuteWorkflow(context.Background(), client.StartWorkflowOptions{
|
run, err := c.ExecuteWorkflow(context.Background(), client.StartWorkflowOptions{
|
||||||
ID: workflowID,
|
ID: workflowID,
|
||||||
TaskQueue: "default",
|
TaskQueue: "poimen-taskqueue",
|
||||||
}, statemachine.OrchestratorWorkflow, input)
|
}, statemachine.OrchestratorWorkflow, input)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Fatalf("failed to start workflow: %v", err)
|
log.Fatalf("failed to start workflow: %v", err)
|
||||||
@@ -96,7 +96,7 @@ func main() {
|
|||||||
|
|
||||||
fmt.Printf("\n=== Workflow Started ===\n")
|
fmt.Printf("\n=== Workflow Started ===\n")
|
||||||
fmt.Printf("Workflow ID: %s\n", workflowID)
|
fmt.Printf("Workflow ID: %s\n", workflowID)
|
||||||
fmt.Printf("Task Queue: default\n")
|
fmt.Printf("Task Queue: poimen-taskqueue\n")
|
||||||
fmt.Printf("\n=== Model Configuration ===\n")
|
fmt.Printf("\n=== Model Configuration ===\n")
|
||||||
fmt.Printf("Planner Model: %s\n", *plannerModel)
|
fmt.Printf("Planner Model: %s\n", *plannerModel)
|
||||||
fmt.Printf("Judge Model: %s\n", *judgeModel)
|
fmt.Printf("Judge Model: %s\n", *judgeModel)
|
||||||
|
|||||||
+2
-2
@@ -29,7 +29,7 @@ func main() {
|
|||||||
defer c.Close()
|
defer c.Close()
|
||||||
|
|
||||||
// Create worker
|
// Create worker
|
||||||
w := worker.New(c, "default", worker.Options{})
|
w := worker.New(c, "poimen-taskqueue", worker.Options{})
|
||||||
if w == nil {
|
if w == nil {
|
||||||
log.Fatalf("failed to create worker")
|
log.Fatalf("failed to create worker")
|
||||||
}
|
}
|
||||||
@@ -55,7 +55,7 @@ func main() {
|
|||||||
// w.RegisterActivity(action.ReadLessonsActivity)
|
// w.RegisterActivity(action.ReadLessonsActivity)
|
||||||
|
|
||||||
// Run worker
|
// Run worker
|
||||||
fmt.Println("Starting worker on queue 'default'...")
|
fmt.Println("Starting worker on queue 'poimen-taskqueue'...")
|
||||||
if err := w.Run(worker.InterruptCh()); err != nil {
|
if err := w.Run(worker.InterruptCh()); err != nil {
|
||||||
log.Fatalf("worker failed: %v", err)
|
log.Fatalf("worker failed: %v", err)
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user