binoua commited on
Commit
d6fbc99
1 Parent(s): df7187e

chore: adding a system to save key piece by piece

Browse files
Files changed (1) hide show
  1. play_with_endpoint.py +18 -6
play_with_endpoint.py CHANGED
@@ -54,17 +54,30 @@ fhemodel_client.generate_private_and_evaluation_keys()
54
  evaluation_keys = fhemodel_client.get_serialized_evaluation_keys()
55
 
56
  # Save the key in the database
57
- evaluation_keys_remaining = evaluation_keys
58
  uid = None
59
  is_first = True
 
 
 
60
 
61
- while sys.getsizeof(evaluation_keys_remaining) > 0:
62
 
63
  # Send by packets of 100M
64
- evaluation_keys_piece = evaluation_keys[: 1024 * 1024 * 100]
65
- evaluation_keys_remaining = evaluation_keys[1024 * 1024 * 100 :]
 
 
 
 
 
 
 
 
 
66
 
67
  if is_first:
 
68
  payload = {
69
  "inputs": "fake",
70
  "evaluation_keys": to_json(evaluation_keys_piece),
@@ -72,6 +85,7 @@ while sys.getsizeof(evaluation_keys_remaining) > 0:
72
  }
73
 
74
  uid = query(payload)["uid"]
 
75
 
76
  else:
77
  payload = {
@@ -83,8 +97,6 @@ while sys.getsizeof(evaluation_keys_remaining) > 0:
83
 
84
  query(payload)
85
 
86
- print(f"Storing the key in the database under {uid=}")
87
-
88
  # Test the handler
89
  nb_good = 0
90
  nb_samples = len(X_test)
 
54
  evaluation_keys = fhemodel_client.get_serialized_evaluation_keys()
55
 
56
  # Save the key in the database
57
+ evaluation_keys_remaining = evaluation_keys[:]
58
  uid = None
59
  is_first = True
60
+ is_finished = False
61
+ i = 0
62
+ packet_size = 1024 * 1024 * 100
63
 
64
+ while not is_finished:
65
 
66
  # Send by packets of 100M
67
+ if sys.getsizeof(evaluation_keys_remaining) > packet_size:
68
+ evaluation_keys_piece = evaluation_keys_remaining[:packet_size]
69
+ evaluation_keys_remaining = evaluation_keys_remaining[packet_size:]
70
+ else:
71
+ evaluation_keys_piece = evaluation_keys_remaining
72
+ is_finished = True
73
+
74
+ print(
75
+ f"Sending {i}-th piece of the key (remaining size is {sys.getsizeof(evaluation_keys_remaining)})"
76
+ )
77
+ i += 1
78
 
79
  if is_first:
80
+ is_first = False
81
  payload = {
82
  "inputs": "fake",
83
  "evaluation_keys": to_json(evaluation_keys_piece),
 
85
  }
86
 
87
  uid = query(payload)["uid"]
88
+ print(f"Storing the key in the database under {uid=}")
89
 
90
  else:
91
  payload = {
 
97
 
98
  query(payload)
99
 
 
 
100
  # Test the handler
101
  nb_good = 0
102
  nb_samples = len(X_test)