Job Administration¶
job_administration — G6 Administration job agent.
Cluster: Job Agents | Type: component | MCP Tools: 26
Overview¶
Domain-specialist job agent for office and administrative operations. Automates document processing, meeting scheduling, records management, correspondence drafting, regulatory filing, workflow analysis, compliance evaluation, and efficiency assessments — covering the full lifecycle of administrative support within a safety-bounded, audit-trailed JobAgentBlock framework.
When to use:
- Processing and routing incoming documents or correspondence at scale
- Scheduling and coordinating meetings across teams with conflict detection
- Auditing administrative workflows for compliance gaps or inefficiencies
- Generating templated reports and managing structured records in a central store
Example:
from mvp.job_administration import JobAdministrationBlock, JobAdministrationInput
block = JobAdministrationBlock()
result = block.infer(JobAdministrationInput(
task="Draft a formal response to the vendor's contract renewal notice and file it in records",
context={"vendor": "Acme Corp", "contract_id": "VC-2024-081"},
))
# result.ok → True; result.value → JobAdministrationOutput with result, artifacts
Works well with: job_framework, job_manager, job_lawyer
Launch Caveat¶
This component is pilot-ready for administrative workflow assistance, not an enterprise records or compliance system. It is suitable for first-customer workflows where a user needs document triage, scheduling support, artifact storage, workflow analysis, and compliance checklists that return quickly and degrade predictably.
Do not treat outputs as legal, regulatory, records-retention, HR, procurement, or safety determinations without qualified human review. Live search and model-backed debate are disabled by default to protect onboarding reliability; enable them explicitly with G6_JOB_ADMINISTRATION_LIVE_INTEGRATIONS=1 when richer analysis is worth the latency and dependency risk. Optional integrations are bounded by G6_JOB_ADMINISTRATION_INTEGRATION_TIMEOUT_SEC or per-call parameters.integration_timeout_sec, and timeout details are surfaced in metadata.integration_warnings.
Architecture note: AdministrationStore is the primary live backend today and persists the component's SQLite-backed documents, schedules, correspondence, procurement, and facilities records. ERPAdapter is an optional passthrough/scaffold abstraction for future ERP integration; the default InMemoryERPAdapter is simulation-only and must not be mistaken for SAP, Oracle, Dynamics, or any other production ERP connector. The current MCP surface reports this status in get_capabilities and does not route write-side ERP methods without explicit review.
Public API¶
JobAdministrationBlock(JobAgentBlock)¶
G6 Administration job agent — Tier 1 block.
| Field | Type | Default |
|---|---|---|
name | str | 'job_administration' |
sector | SectorClassification | field(default_factory=lambda: _SECTOR) |
toolkit | ToolkitSpec \| None | field(default_factory=lambda: JOB_TOOLKITS.get('administration')) |
mcp_module | str | 'mvp.job_administration.administration_mcp.server' |
agentic_planner | object \| None | None |
capabilities | ClassVar[set[type]] | {Extensible, HumanLearnable, Collaborative, ProblemSolvable, KnowledgeGrounded, Memorable, AgentCommunicable} |
Methods:
infer(data: object) -> Result[JobAdministrationOutput]¶
JobAdministrationInput(JobInput)¶
Input for the Administration job agent.
JobAdministrationOutput(JobOutput)¶
JobAdministrationMCPBlock(AIBlock[MCPJobAdministrationInput, MCPJobAdministrationOutput, dict])¶
26-op MCP block for the Administration job agent.
| Field | Type | Default |
|---|---|---|
name | str | 'job_administration_mcp' |
state | dict | field(default_factory=dict) |
db_path | str | ':memory:' |
resource_bounds | ResourceBounds | field(default_factory=ResourceBounds) |
usage | ResourceUsage | field(default_factory=ResourceUsage) |
Methods:
infer(data: MCPJobAdministrationInput) -> Result[MCPJobAdministrationOutput]¶
MCPJobAdministrationInput(BaseModel)¶
Input to JobAdministrationMCPBlock — 26-op dispatch.
| Field | Type | Default |
|---|---|---|
op | Literal['process_document', 'schedule_meeting', 'manage_records', 'draft_correspondence', 'file_report', 'analyze_workflow', 'evaluate_compliance', 'assess_efficiency', 'benchmark_processing', 'audit_records', 'create_proposal', 'review_deliverable', 'delegate_task', 'report_status', 'request_feedback', 'store_artifact', 'retrieve_artifact', 'list_artifacts', 'search_artifacts', 'archive', 'plan_sprint', 'track_progress', 'reflect_on_outcome', 'list_patterns', 'get_capabilities', 'info'] | required |
task | str | '' |
context | dict[str, Any] | Field(default_factory=dict) |
parameters | dict[str, Any] | Field(default_factory=dict) |
artifact_id | str | '' |
query | str | '' |
MCPJobAdministrationOutput(BaseModel)¶
Output from JobAdministrationMCPBlock.
| Field | Type | Default |
|---|---|---|
op | str | required |
result | str | '' |
artifacts | list[dict[str, Any]] | Field(default_factory=list) |
records | list[dict[str, Any]] | Field(default_factory=list) |
message | str | '' |
count | int | 0 |
found | bool | False |
metadata | dict[str, Any] | Field(default_factory=dict) |
degraded | bool | False |
degradation_reason | str \| None | None |
completion_state | Literal['verified', 'qualified-draft', 'blocked-escalated'] | 'qualified-draft' |
warning_card | dict[str, Any] | Field(default_factory=dict) |
evidence | dict[str, Any] | Field(default_factory=dict) |
request_id | str | '' |
task_id | str | '' |
run_id | str | '' |
AdministrationStore(JobStore)¶
SQLite store for the Administration job agent.
Constructor:
| Parameter | Type | Default |
|---|---|---|
db_path | str | ':memory:' |
Methods:
create_document(title: str, doc_type: str = '', category: str = '', author: str = '', content: dict | None = None, status: str = 'draft') -> str¶
get_document(doc_id: str) -> dict | None¶
list_documents(category: str = '', status: str = '') -> list[dict]¶
update_document_status(doc_id: str, status: str) -> bool¶
increment_document_version(doc_id: str) -> int¶
create_schedule(title: str, event_type: str = '', organizer: str = '', attendees: list[str] | None = None, start_time: str = '', end_time: str = '', location: str = '', recurrence: dict | None = None) -> str¶
get_schedule(schedule_id: str) -> dict | None¶
list_schedules(event_type: str = '', status: str = '') -> list[dict]¶
update_schedule_status(schedule_id: str, status: str) -> bool¶
create_correspondence(direction: str = 'outbound', counterparty: str = '', subject: str = '', body: str = '', attachments: list[str] | None = None, priority: str = 'normal') -> str¶
get_correspondence(corr_id: str) -> dict | None¶
list_correspondence(direction: str = '', priority: str = '', status: str = '') -> list[dict]¶
update_correspondence_status(corr_id: str, status: str) -> bool¶
create_order(vendor: str, items: list[dict] | None = None, total_amount: float = 0, data: dict | None = None) -> str¶
get_order(order_id: str) -> dict | None¶
list_orders(vendor: str = '', approval_status: str = '') -> list[dict]¶
update_order_approval(order_id: str, approval_status: str) -> bool¶
mark_order_received(order_id: str) -> bool¶
create_facility(name: str, location: str = '', capacity: int = 0, equipment: list[str] | None = None, maintenance: list[dict] | None = None) -> str¶
get_facility(facility_id: str) -> dict | None¶
list_facilities(status: str = '') -> list[dict]¶
update_facility_status(facility_id: str, status: str) -> bool¶
update_facility_maintenance(facility_id: str, maintenance: list[dict]) -> bool¶
Functions¶
assemble_review_text(output: Any) -> str¶
Collect the reviewable free text from a JobAdministrationOutput (duck-typed).
assess_administration_output(output: Any, qa_block: Any | None = None, generate: Any | None = None) -> GroundedRunResult¶
Run grounded four-valued QA over an administration output.
MCP Tools¶
| Operation | Source |
|---|---|
process_document | administration_mcp |
schedule_meeting | administration_mcp |
manage_records | administration_mcp |
draft_correspondence | administration_mcp |
file_report | administration_mcp |
analyze_workflow | administration_mcp |
evaluate_compliance | administration_mcp |
assess_efficiency | administration_mcp |
benchmark_processing | administration_mcp |
audit_records | administration_mcp |
create_proposal | administration_mcp |
review_deliverable | administration_mcp |
delegate_task | administration_mcp |
report_status | administration_mcp |
request_feedback | administration_mcp |
store_artifact | administration_mcp |
retrieve_artifact | administration_mcp |
list_artifacts | administration_mcp |
search_artifacts | administration_mcp |
archive | administration_mcp |
plan_sprint | administration_mcp |
track_progress | administration_mcp |
reflect_on_outcome | administration_mcp |
list_patterns | administration_mcp |
get_capabilities | administration_mcp |
info | administration_mcp |