nvflare.edge.utils module

message_topic_for_task_end(task_name: str) → str[source]
message_topic_for_task_update(task_name: str) → str[source]
process_update_from_child(processor: ~nvflare.apis.fl_component.FLComponent, update: ~nvflare.apis.shareable.Shareable, current_task_seq: int, fl_ctx: ~nvflare.apis.fl_context.FLContext, update_f, **kwargs) -> (<class 'bool'>, <class 'nvflare.apis.shareable.Shareable'>)[source]

Process aggregation report sent from a child client.

Parameters:

  • processor – the component that received the update report from the child.

  • update – the report request

  • current_task_seq – sequence number of the current task

  • fl_ctx – FLContext object

  • update_f – the function to be called to process the update report

  • **kwargs – args to be passed to update_f

Returns: a tuple of (whether the report is accepted, reply to be sent back to the reporter).