nvflare.collab.runtime.dispatch module

class CollabCallAuthorizer(app: App, local_fqcn: str, participants: dict[str, str], logger)

Bases: object

Authorizes a Collab call before deserialization and application dispatch.

The participant lookup relies on CellNet’s authenticated ORIGIN. Secure deployments bind that identity to connection credentials; insecure CellNet deployments do not provide the same identity guarantee.

authorize(headers: dict) → StreamError | None

make_participant_map(server_fqcn: str, job_id: str, clients) → dict[str, str]

Build an exact job-cell FQCN to logical Collab name mapping.

prepare_for_remote_call(cell, app, logger, executor, participants: dict[str, str])