Output
SS
D
await instance.status() only gives me the output of the steps inside the workflow, not the workflow return value.
Fawait instance.status().output
I
status()output(await instance.status()).outputDoutputInstanceStatus does not contain the Workflow return value, even when the workflow is completed. I'm only seeing an array of the outputs from the individual steps called inside the workflow.
OOO
K
SD
Promise.all is fine.saveNotesStep after the Promise.all and reading the output of the step. In that case if the "save" step fails, the generateNotesStep will have cached the response. It might only be an issue if the serialized data exceeds the limits.OOODD
DBecause Workflows can be long running, it is possible to have running instances that represent different versions of your Workflow code over time.Does it mean that if, for example, I update my code while the workflow is waiting a
sleep() step, when the sleep is over it will execute the old code and not the updated steps (considering that the step names are the same if it matters)?
H
WHDDDW
DDD
D
I
OOOOO
body.record and they aren't nullO
OOW
Serialized RPC arguments or return values are limited to 1MiB error
MMS
await instance.status()await instance.status().output(await instance.status()).outputInstanceStatusPromise.allPromise.allsaveNotesStepgenerateNotesStepsleep()body.recordSerialized RPC arguments or return values are limited to 1MiBconst generateTitleStep = step.do(
"Generate the project title",
async () => {
console.log("Generate the project title");
const anthropic = createAnthropic({
apiKey: this.env.ANTHROPIC_API_KEY,
});
return {};
},
);
const generateNotesStep = step.do(
"Generate the project notes",
async () => {
console.log("Generate the project notes");
return {};
},
);
// option A
await step.do("Await all project generation steps", async () => {
await generateTitleStep;
await generateNotesStep;
});
// option B
await Promise.all([generateTitleStep, generateNotesStep]);const generateNotesStep = step.do(
"Generate the project notes",
async () => {
console.log("Generate the project notes");
return "These are some notes returned after awaiting";
},
);
const saveNotesStep = step.do(
"Save the project notes",
async () => {
const notes = await generateNotesStep
// save the data to the DB here. notes have been generated and won't regenerate if this retries
return {};
},
);const workflowBody: WorkflowParams = {
coursework: {
id: body.record.id,
...
},
prompt_id: body.record.prompt_id,
};
await env.grading_workflow.create({
id: submissionId,
params: workflowBody,
});