longpeng/Beacon
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

更新任务队列名称，将 Python 和 Go Worker 的任务队列分别改为 "python-task-queue" 和 "data-task-queue" 以保持一致性

Browse Source
This commit is contained in:
longpeng 2025-06-25 14:53:07 +08:00
parent ae42336160
commit a299cf384c
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
workers/go/workers.go
View File

@ -19,7 +19,7 @@ func StartWorkflow(cnf *config.TemporalConfig) error {
} }
defer c.Close() defer c.Close()
taskQueue := "test-task-queue" taskQueue := "data-task-queue"
// 创建一个监听指定任务队列的 Worker。 // 创建一个监听指定任务队列的 Worker。
w := worker.New(c, taskQueue, worker.Options{}) w := worker.New(c, taskQueue, worker.Options{})

2
workers/python/main.py
View File

@ -19,7 +19,7 @@ async def main():
# 创建 Worker # 创建 Worker
worker = Worker( worker = Worker(
client, client,
task_queue="test-task-queue", # 保持与 Go Client 一致 task_queue="python-task-queue", # 保持与 Go Client 一致
activities=[activities.run_api_test,activities.run_ui_test] activities=[activities.run_api_test,activities.run_ui_test]
) )
print("Starting Python Temporal Worker...") print("Starting Python Temporal Worker...")