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¶