flip.nvflare.executors.validator

RUN_VALIDATOR Executor.

This module provides the RUN_VALIDATOR executor that wraps user-provided FLIP_VALIDATOR classes with error handling.

Classes

RUN_VALIDATOR

Wrapper executor that runs user-provided FLIP_VALIDATOR implementations.

Module Contents

class flip.nvflare.executors.validator.RUN_VALIDATOR(validate_task_name=AppConstants.TASK_VALIDATION, project_id='', query='')[source]

Bases: nvflare.apis.executor.Executor

Wrapper executor that runs user-provided FLIP_VALIDATOR implementations.

This executor handles: - Dynamic importing of the user’s FLIP_VALIDATOR class - Error handling and exception logging - Lazy initialization of the validator instance

Initialize the RUN_VALIDATOR executor.

Parameters:

validate_task_name – Task name for validation task. Defaults to “validate”.
project_id – The ID of the project the model belongs to.
query – The cohort query that is associated with the project.

execute(task_name: str, shareable: nvflare.apis.shareable.Shareable, fl_ctx: nvflare.apis.fl_context.FLContext, abort_signal: nvflare.apis.signal.Signal) → nvflare.apis.shareable.Shareable[source]

Execute the validation task.

This method: 1. Lazily imports and initializes the user’s FLIP_VALIDATOR 2. Delegates execution to the user’s validator 3. Catches and reports any exceptions

Parameters:

task_name – The name of the task to execute
shareable – The input shareable data
fl_ctx – The FL context
abort_signal – Signal for aborting the task

Returns:

Shareable – The result of the validation task