nvflare.client.ipc.defs module¶

exception AgentClosed[source]¶: Bases: Exception

exception CallStateError[source]¶: Bases: Exception

class MetaKey[source]¶

Bases: object

CURRENT_ROUND = 'current_round'¶

DATA_KIND = 'data_kind'¶

FILTER_HISTORY = 'filter_history'¶

INITIAL_METRICS = 'initial_metrics'¶

NUM_STEPS_CURRENT_ROUND = 'NUM_STEPS_CURRENT_ROUND'¶

PROCESSED_ALGORITHM = 'PROCESSED_ALGORITHM'¶

PROCESSED_KEYS = 'PROCESSED_KEYS'¶

TOTAL_ROUND = 'total_round'¶

class MsgHeader[source]¶

Bases: object

RC = 'rc'¶

TASK_ID = 'task_id'¶

TASK_NAME = 'task_name'¶

class PayloadKey[source]¶

Bases: object

DATA = 'data'¶

META = 'meta'¶

class Task(task_name: str, task_id: str, meta: dict, data)[source]¶

Bases: object

FETCHED = 1¶

NEW = 0¶

PROCESSED = 2¶

class TaskResult(meta: dict, data, return_code='OK')[source]¶: Bases: object

agent_site_fqcn(site_name: str, agent_id: str)[source]¶