linkedin.asisaga.com azure-functions.instructions.md

Azure Functions & AOS Workflow Patterns

AOSApp Setup

Every workflow module starts with a single AOSApp instance:

from aos_client import AOSApp, ObservabilityConfig

# App name comes from repository spec — see .github/specs/repository.md
app = AOSApp(
    name="<app-name>",
    observability=ObservabilityConfig(
        structured_logging=True,
        correlation_tracking=True,
        health_checks=["aos", "service-bus"],
    ),
)

The SDK provisions HTTP triggers, Service Bus triggers, health endpoints, and auth — no boilerplate needed here.

Workflow Registration

@app.workflow("workflow-name")
async def workflow_fn(request: WorkflowRequest) -> Dict[str, Any]:
    ...

• Workflow names use kebab-case
• Return {"orchestration_id": ..., "status": ...} for orchestration starters
• Return plain data dicts for query/lookup workflows

Azure Functions Entry Point

# function_app.py — zero boilerplate
from <package>.workflows import app
functions = app.get_functions()

Never add Azure Functions decorators directly to function_app.py.

Orchestration Patterns

Perpetual orchestration (most workflows)

status = await request.client.start_orchestration(
    agent_ids=agent_ids,
    purpose="Describe the ongoing goal",
    purpose_scope="Scope of responsibility",
    context=request.body,
)
return {"orchestration_id": status.orchestration_id, "status": status.status.value}

Sequential workflow

status = await request.client.start_orchestration(
    ...,
    workflow="sequential",
)

Hierarchical workflow

status = await request.client.start_orchestration(
    ...,
    workflow="hierarchical",
)

Advanced: OrchestrationRequest with MCP servers

from aos_client import MCPServerConfig, OrchestrationPurpose, OrchestrationRequest

req = OrchestrationRequest(
    agent_ids=agent_ids,
    purpose=OrchestrationPurpose(purpose=..., purpose_scope=...),
    context=request.body,
    mcp_servers={agent_id: [MCPServerConfig(server_name="erp")]},
)
status = await request.client.submit_orchestration(req)