Getting Started with Agent Workflow

Workflow.define("pr-review")
    .step(fetchDiff)
    .then(analyzeDiff)
    .gate(new JudgeGate(jury, 0.8))
        .onPass(postComment)
        .onFail(revise)
    .end()
    .run(event);

Step<Object, Object> fetchDiff = Step.named("fetch-diff", (ctx, in) -> {
    // Call GitHub API, return the diff as a string
    return gitHub.getPullRequest(in).getDiff();
});

Workflow
  └── Step: FetchPR          [deterministic — GitHub API call]
  └── Step: AnalyzeDiff      [ClaudeStep — full agent loop internally]
                                  ├── LLM turn 1 → tool call → result
                                  ├── LLM turn 2 → tool call → result
                                  └── LLM turn N → finish
  └── Step: AssembleReport   [deterministic — string formatting]

ChatClient chat = ChatClient.builder(chatModel).build();

Step<Object, Object> write = Step.named("write", (ctx, in) ->
        chat.prompt()
                .user("Write a 3-sentence story about: " + in)
                .call().content());

// Define typed keys
static final ContextKey<String> DIFF = ContextKey.of("diff", String.class);
static final ContextKey<Double> RISK_SCORE = ContextKey.of("risk-score", Double.class);

// Step reads from context and writes back
Step<Object, Object> assessRisk = Step.named("assess-risk", (ctx, in) -> {
    String diff = ctx.require(DIFF);          // read upstream output
    double score = evaluateRisk(diff);
    // score becomes this step's output, available to downstream steps
    return score;
});

Step<Object, Object> write = Step.named("write", (ctx, in) ->
        chat.prompt()
                .user("Write a 3-sentence story about: " + in)
                .call().content());

Step<Object, Object> editForAudience = Step.named("edit-audience", (ctx, in) ->
        chat.prompt()
                .user("Rewrite for young adults. Return only the story: " + in)
                .call().content());

Step<Object, Object> editForStyle = Step.named("edit-style", (ctx, in) ->
        chat.prompt()
                .user("Rewrite in a humorous style. Return only the story: " + in)
                .call().content());

String result = (String) Workflow.<String, Object>define("novel-creator")
        .step(write)
        .then(editForAudience)
        .then(editForStyle)
        .run("dragons and wizards");

<dependency>
    <groupId>io.github.markpollack</groupId>
    <artifactId>workflow-flows</artifactId>
    <version>0.10.0</version>
</dependency>