nvflare.app_common.psi.dh_psi.dh_psi_workflow module

class DhPSIWorkFlow(bloom_filter_fpr: float = 1e-11)

Bases: PSIWorkflow

Init FLComponent.

The FLComponent is the base class of all FL Components. (executors, controllers, responders, filters, aggregators, and widgets are all FLComponents)

FLComponents have the capability to handle and fire events and contain various methods for logging.

backward_pass(ordered_clients: list, intersect_site: SiteSize) → dict

calculate_intersections(response_msg) → Dict[str, int]

check_final_intersection_sizes(intersect_site: SiteSize)

check_processed_sites(last_site: SiteSize, processed_sites: Dict[str, int])

create_requests(site_setup_msgs) → Dict[str, str]

finalize(fl_ctx: FLContext)

forward_pass(ordered_sites: List[SiteSize], processed: Dict[str, int]) → SiteSize

static get_ordered_sites(results: Dict[str, DXO])

get_updated_site_sizes(ordered_sites)

initialize(fl_ctx: FLContext, **kwargs)

log_pass_time_taken()

pairwise_intersect(ordered_sites: List[SiteSize], response_msg: Dict[str, str])

pairwise_requests(ordered_sites: List[SiteSize], setup_msgs: Dict[str, str])

pairwise_responses(ordered_sites: List[SiteSize], request_msgs: Dict[str, str])

pairwise_setup(ordered_sites: List[SiteSize])

parallel_backward_pass(ordered_clients: list, intersect_site: SiteSize)

parallel_forward_pass(target_sites, processed: dict)

post_process(abort_signal: Signal)

pre_process(abort_signal: Signal) → bool

prepare_setup_messages(s: SiteSize, other_site_sizes: Set[int]) → Dict[str, str]

prepare_sites(abort_signal)

process_requests(s: SiteSize, request_msgs: Dict[str, str]) → Dict[str, str]

run(abort_signal: Signal)

class SiteSize(name, size)

Bases: tuple

Create new instance of SiteSize(name, size)

name: str

Alias for field number 0

size: int

Alias for field number 1