Searched refs:num_inputs_aggregated_and_included (Results 1 – 4 of 4) sorted by relevance
73 num_inputs_aggregated_and_included: int = 0 variable in SessionStatus108 num_inputs_aggregated_and_included: Optional[int]247 if (state.agg_protocol.GetStatus().num_inputs_aggregated_and_included <289 num_inputs_aggregated_and_included: Optional[int] = None296 if (num_inputs_aggregated_and_included is None or297 num_inputs_aggregated_and_included <=298 status.num_inputs_aggregated_and_included):301 wait_data = _WaitData(num_inputs_aggregated_and_included)352 num_inputs_aggregated_and_included=(353 status.num_inputs_aggregated_and_included),[all …]
144 num_inputs_aggregated_and_included=num_clients))172 num_inputs_aggregated_and_included=required_clients)177 agg_status.num_inputs_aggregated_and_included)178 agg_status.num_inputs_aggregated_and_included = 0211 num_inputs_aggregated_and_included=required_clients)216 agg_status.num_inputs_aggregated_and_included)217 agg_status.num_inputs_aggregated_and_included = 0339 service.wait(session_id, num_inputs_aggregated_and_included=1))368 num_inputs_aggregated_and_included=1))394 service.wait(session_id, num_inputs_aggregated_and_included=1))[all …]
144 num_inputs_aggregated_and_included=number_of_clients)
103 // num_clients_completed = num_inputs_aggregated_and_included109 int64 num_inputs_aggregated_and_included = 5; field