nvflare.edge.simulation.device_task_processor module

class DeviceTaskProcessor[source]

Bases: ABC

The spec for a task processor that handles tasks on edge devices

cancel() → None[source]: Cancel the task processing

property device_info

property job_data

property job_id

property job_method

property job_name

abstract process_task(task: TaskResponse) → dict[source]

Process a task and return the result. This method is repeated for each task until all tasks are done

Parameters:: task – The task information from server
Returns:: The result as a dict

abstract setup(job: JobResponse) → None[source]

Setup for a new job

Args: device: the SimulatedDevice object job: Job information returned by server

abstract shutdown() → None[source]: Clean-up the resources allocated for the job and get ready for next

property user_info