Merge pull request #137 from restackio/bumpTodos

Agent Todos Bump add task queues

Author: aboutphilippe

agent-todo/package.json

@@ -10,7 +10,7 @@
     "event": "tsx eventAgent.ts"
   },
   "dependencies": {
-    "@restackio/ai": "^0.0.109",
+    "@restackio/ai": "^0.0.121",
     "@temporalio/workflow": "1.11.6",
     "dotenv": "^16.4.7",
     "openai": "^4.80.1",

agent-todo/src/agents/agent.ts

@@ -67,6 +67,7 @@ export async function agentTodo(): Promise<agentTodoOutput> {
               child: executeTodoWorkflow,
               childId: workflowId,
               input: JSON.parse(toolCall.function.arguments),
+              taskQueue: "todo-workflows",
             });
 
             agentMessages.push({

agent-todo/src/services.ts

@@ -18,6 +18,7 @@ async function services() {
       }),
       client.startService({
         workflowsPath: workflowsPath,
+        taskQueue: "todo-workflows",
         functions: { getRandom, getResult },
       }),
     ]);

agent-todo/src/workflows/executeTodo.ts

@@ -17,13 +17,13 @@ export async function executeTodoWorkflow({
   todoTitle,
   todoId,
 }: Input): Promise<Output> {
-  const random = await step<typeof functions>({}).getRandom({
+  const random = await step<typeof functions>({taskQueue: "todo-workflows",}).getRandom({
     todoTitle,
   });
 
   await sleep(2000);
 
-  const result = await step<typeof functions>({}).getResult({
+  const result = await step<typeof functions>({taskQueue: "todo-workflows",}).getResult({
     todoTitle,
     todoId,
   });