dispatch

func BuildWorkerCommand ¶

func BuildWorkerCommand(bin string, spec Spec) (*exec.Cmd, error)

BuildWorkerCommand assembles the `bones tasks dispatch worker` invocation with the required flags wired from spec. The parent appends per-result flags (--result, --summary, --claim-from-agent-id) before Start.

Earlier iterations passed these as AGENT_INFRA_* env vars, but the worker's Kong struct never read them — the worker would fail Kong's required-flag validation immediately and the parent would hit its 5s subscribe timeout. Flags-only is the single source of truth.

func FormatResult ¶

func FormatResult(msg ResultMessage) string

func ReclaimClaim ¶

func ReclaimClaim(
	ctx context.Context,
	c *coord.Coord,
	taskID coord.TaskID,
	ttl time.Duration,
) (func() error, error)

func WaitWorkerAbsent ¶

func WaitWorkerAbsent(
	ctx context.Context,
	c *coord.Coord,
	workerAgentID string,
	deadline time.Duration,
) error