Heng Pan issues

Results 45 issues of


                                            Heng Pan

Fix the module doc string of `secaggplus_mod.py` and `secaggplus_mod_test.py`.

Use `warn_deprecated_feature` in `message_handler.py`

Update `Metadata` and `Message` class

Replace `GrpcDriver` with `Driver` in the `start_driver()` function.

- Replaced `GrpcDriver` with `Driver` in `start_driver()` - Replaced `GrpcDriver` with `Driver` in `DriverClientProxy` - Removed sync lock - Added `ref_exit_flag = [False]`, which is used to "kill" the thread...

Augment `Driver` class with error handling via `RetryInvoker`

- Added a sync lock for Driver API calls in the `Driver` class to prevent potential thread conflicts - Wrapped all Driver API calls within `RetryInvoker`. - Added new unit...

Add `insecure` arg to `start_server`

- Added `insecure` arg to `start_server`. - Added `sys.exit` when both `insecure` and `certificates` are set.

Add `eq` and `repr` to classes

# Now: ![image](https://github.com/adap/flower/assets/134433891/72d1fc6a-2df0-425b-bc5e-0272ca49dce0) # Previous: ![image](https://github.com/adap/flower/assets/134433891/a9179cd8-22bf-474b-9536-d8d44c99a42a)

Add flags to `InMemoryState` for the simulation engine

In simulation mode, In`MemoryDriver` and `vce_api.py` must periodically check for new `TaskIns`/`TaskRes` in the `InMemoryState`. Due to performance concerns, we now have `State.get_task_res` called by `InMemoryDriver` every 3 seconds and...

Implement `run_supernode`

- Call `get_run` and pass `fab_id` & `fab_version` to `load_client_app_fn` in the `_start_client_internal` function. - Implement the `run_supernode` - Merge common logic of `run_client_app` and `run_supernode` > The `load_client_app_fn` function...