README
¶
Agent Task Executor
Kafka event consumer + Kubernetes Job spawner for the
bborbe/agent task system. It consumes
task.CreateCommand events, matches each task's assignee to a registered agent
Config CR (agent.benjamin-borbe.de/v1), and spawns one Kubernetes Job per
task/phase using that agent's image, env, resources and secrets — propagating
BRANCH / TOPIC_PREFIX to the child Job.
Image tags: an agent Config.spec.image that already carries a tag (a semver
pin, e.g. …/agent-claude:v0.1.1) is used as-is; an untagged image gets the
running branch appended (…/agent-backtest → …/agent-backtest:dev). Deployed
via the agent Helm chart; published image docker.io/bborbe/agent-task-executor.
Reconcile loop configuration
The reconcile loop re-derives running tasks from the vault (via git-rest) and
live Jobs, so a task deferred behind maxConcurrentJobs whose in-memory
deferral was lost across an executor restart resumes without a Kafka event or
vault edit. It is configured by:
| Env var | Default | Meaning |
|---|---|---|
GITREST_URL |
http://vault-obsidian-openclaw:9090 |
git-rest HTTP API base URL the reconcile loop reads vault task files through. |
GITREST_GATEWAY_SECRET |
empty (auth disabled) | NAME of the K8s Secret carrying the git-rest gateway secret (data key gateway-secret) — never the secret value. The executor reads the value from the Secret at startup and uses it only in memory. The executor's ServiceAccount must be able to get this Secret (chart-side Role grant). |
TASK_GLOB |
24 Tasks/*.md |
git-rest single-level glob selecting the vault task files the reconcile loop evaluates. |
Links
Dev: https://dev.quant.benjamin-borbe.de/admin/agent-task-executor/setloglevel/3 https://dev.quant.benjamin-borbe.de/admin/agent-task-executor/agents https://dev.quant.benjamin-borbe.de/admin/agent-task-executor/healthcheck-trigger
Prod: https://prod.quant.benjamin-borbe.de/admin/agent-task-executor/setloglevel/3 https://prod.quant.benjamin-borbe.de/admin/agent-task-executor/agents https://prod.quant.benjamin-borbe.de/admin/agent-task-executor/healthcheck-trigger
License
This project is licensed under the BSD-style license. See the LICENSE file for details.
Documentation
¶
There is no documentation for this package.
Source Files
Directories
¶
| Path | Synopsis |
|---|---|
|
k8s
|
|
|
apis/agent.benjamin-borbe.de/v1
Package v1 is the v1 version of the Config API.
|
Package v1 is the v1 version of the Config API. |
|
client/clientset/versioned/fake
This package has the automatically generated fake clientset.
|
This package has the automatically generated fake clientset. |
|
client/clientset/versioned/scheme
This package contains the scheme of the automatically generated clientset.
|
This package contains the scheme of the automatically generated clientset. |
|
client/clientset/versioned/typed/agent.benjamin-borbe.de/v1
This package has the automatically generated typed clients.
|
This package has the automatically generated typed clients. |
|
client/clientset/versioned/typed/agent.benjamin-borbe.de/v1/fake
Package fake has the automatically generated clients.
|
Package fake has the automatically generated clients. |
|
Code generated by counterfeiter.
|
Code generated by counterfeiter. |
|
probe/mocks
Code generated by counterfeiter.
|
Code generated by counterfeiter. |