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]