Class EmailShiftDoer

java.lang.Object

ai.redouble.nucleo.harness.AbstractJob<List<String>>

ai.redouble.nucleo.tools.AbstractTool<String, List<String>>

ai.redouble.nucleo.tools.AbstractOrchestrator<String, List<String>>

ai.redouble.nucleo.tools.AbstractDoer<String, List<String>>

ai.redouble.examples.scopes.EmailShiftDoer

All Implemented Interfaces:

CaseScoped, ChannelScoped, GuardedExecution, ScopeAuthority, Scoped, Identifiable, Job<List<String>>, Doer<String, List<String>>, Orchestrator<String, List<String>>, Tool<String, List<String>>

public class EmailShiftDoer
extends AbstractDoer<String, List<String>>
implements CaseScoped, ChannelScoped

The shift: one customer's case, worked on the email channel. Real work overlaps several axes at once, and two unrelated bindings on one flow means implementing both markers; that leaves the class with two default scope() methods, so the compiler forces the composite override - one flow answering for both axes.

Partway through, the shift escalates one disputed order by spawning DisputeDoer: from that point the case axis is narrowed to one order for everything the escalation does, while the shift's own bindings ride into it through the runtime and keep holding.

Since:

0.1 (2026-09-28)

Author:

Andrey Santrosyan

Field Summary

Fields inherited from class AbstractOrchestrator

META_ITERATION

Fields inherited from class AbstractTool

input

Fields inherited from class AbstractJob

timeout, upstreamRetries

Fields inherited from interface Job

DEFAULT_UPSTREAM_RETRIES

Fields inherited from interface Tool

OBS_INPUT, OBS_OUTPUT

Constructor Summary

Constructors

Constructor	Description
EmailShiftDoer(Identifiable parent, String customerId)

Method Summary

Modifier and Type	Method	Description
List<String>	execute(JobContext<List<String>> context)	Main execution - spawn jobs, wait on handles, return when done.
String	getChannel()
String	getCustomerId()
Scope	scope()

Methods inherited from class AbstractDoer

nextStep, submitInCurrentStep, submitInCurrentStep, submitInCurrentStep, submitInStep

Methods inherited from class AbstractOrchestrator

execute, getJobType, getRequirements, getScopeGuard, getTimeout, sealScopeGuard, setScopeGuard, setTimeout, submitInIteration, submitInIteration, submitInIteration

Methods inherited from class AbstractTool

getInput, postExecute, preExecute, setInput

Methods inherited from class AbstractJob

getId, getName, getParentJobId, getPriority, getUpstreamRetries, getUserId, getWorkflowId, randomIdSuffix, setUpstreamRetries, toString

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface GuardedExecution

declareAdmissionGuardrails, declareAuthGuardrails, declareContentGuardrails

Methods inherited from interface Identifiable

getParentJobId, getUserId, getWorkflowId

Methods inherited from interface Job

getDisplayName, getId, getJobId, getJobType, getName, getPriority, getRequirements, getTimeout, getUpstreamRetries, postExecute, preExecute

Methods inherited from interface ScopeAuthority

getScopeGuard, sealScopeGuard, setScopeGuard

Methods inherited from interface Tool

execute, getInput, guardedInputTarget, setInput

Constructor Details

EmailShiftDoer

public EmailShiftDoer(Identifiable parent,
 String customerId)

Method Details

getCustomerId

public String getCustomerId()

Specified by:

getCustomerId in interface CaseScoped

getChannel

public String getChannel()

Specified by:

getChannel in interface ChannelScoped

scope

public Scope scope()

Specified by:

scope in interface CaseScoped

Specified by:

scope in interface ChannelScoped

Specified by:

scope in interface Scoped

execute

public List<String> execute(JobContext<List<String>> context)
                     throws LLMReadableCheckedException

Description copied from class: AbstractOrchestrator

Main execution - spawn jobs, wait on handles, return when done.

Write natural Java code. Spawn children through the iteration-stamping helpers (AbstractOrchestrator.submitInIteration(long, Job), or a doer's step helpers), call handle.get() to wait. Branch, loop, whatever. Return when done.

Specified by:

execute in class AbstractOrchestrator<String, List<String>>

Parameters:

context - the job context for progress reporting and cancellation

Returns:

the result of the coordinator's work

Throws:

LLMReadableCheckedException - if coordination fails