Skip to content

Commit

Permalink
Rerun pybind notebooks with new version no
Browse files Browse the repository at this point in the history
  • Loading branch information
Xinxin (Cissie) Mei authored and cissieAB committed Sep 16, 2024
1 parent abf7f99 commit 351e7bf
Show file tree
Hide file tree
Showing 4 changed files with 308 additions and 85 deletions.
61 changes: 31 additions & 30 deletions scripts/notebooks/pybind11_examples/example_ControlPlane.ipynb
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@
"name": "stdout",
"output_type": "stream",
"text": [
"0.1.0\n"
"0.1.1\n"
]
}
],
Expand Down Expand Up @@ -72,7 +72,7 @@
"Defaulting to user installation because normal site-packages is not writeable\n",
"Requirement already satisfied: protobuf in /home/ubuntu/.local/lib/python3.10/site-packages (5.28.1)\n",
"Note: you may need to restart the kernel to use updated packages.\n",
"Timestamp: seconds = 1726507802, nanos = 990104000\n"
"Timestamp: seconds = 1726512856, nanos = 809628000\n"
]
}
],
Expand Down Expand Up @@ -120,8 +120,8 @@
"Worker control signal: 0.8999999761581421\n",
"Worker slots assigned: 10\n",
"Worker last_updated (following 2 lines):\n",
"seconds: 1726507802\n",
"nanos: 990104000\n",
"seconds: 1726512856\n",
"nanos: 809628000\n",
"\n"
]
}
Expand Down Expand Up @@ -327,7 +327,7 @@
"name": "stdout",
"output_type": "stream",
"text": [
"Instance token: 037cd85578669e455f5801f2eeb7b5ce3cbdd2025d2153d28a2e5c64884e9a1f\n"
"Instance token: 9b0a986e06d5983e79e71904a6dba3fdb3aef7065d4b81e639c7ea66fedc2b45\n"
]
}
],
Expand Down Expand Up @@ -398,7 +398,7 @@
"output_type": "stream",
"text": [
"Sync IPv4 addr is: 192.168.0.3\n",
"LB id is: 2\n"
"LB id is: 16\n"
]
}
],
Expand Down Expand Up @@ -554,7 +554,7 @@
"name": "stdout",
"output_type": "stream",
"text": [
"LB ID is: 3\n"
"LB ID is: 17\n"
]
}
],
Expand Down Expand Up @@ -677,8 +677,8 @@
"\n",
"Send state succeeded\n",
"\n",
"Session id is: 1\n",
"Session token is: 7f4cfb2438e461784dcff9be6ab3abb07462fb4ec507e273b2e2b5dffbf79f55\n",
"Session id is: 9\n",
"Session token is: 53d47321eecfc42cdb7999649c9bc9bd197d39e3b32830e5a3028bc83cfba473\n",
"\n",
"Deregister worker succeeded\n"
]
Expand Down Expand Up @@ -795,7 +795,7 @@
"\n",
"Send state for 25 times\n",
"\n",
"Get LB status succeeded: <e2sar_py.ControlPlane.LoadBalancerStatusReply object at 0x7f674031c5f0>\n"
"Get LB status succeeded: <e2sar_py.ControlPlane.LoadBalancerStatusReply object at 0x7fe905535430>\n"
]
}
],
Expand Down Expand Up @@ -857,14 +857,14 @@
"name": "stdout",
"output_type": "stream",
"text": [
"Timestamp: seconds: 1726507806\n",
"nanos: 689280748\n",
"Timestamp: seconds: 1726512860\n",
"nanos: 102211657\n",
"\n",
"expiresAt: seconds: 1726511404\n",
"expiresAt: seconds: 1726516457\n",
"\n",
"currentEpoch: 3\n",
"currentPredictedEventNumber: 9223372036854775808\n",
"workers: [<e2sar_py.ControlPlane.WorkerStatus object at 0x7f671b46b1f0>]\n"
"workers: [<e2sar_py.ControlPlane.WorkerStatus object at 0x7fe8ed783970>]\n"
]
}
],
Expand Down Expand Up @@ -925,16 +925,16 @@
"Create LBManager obj succeeded: 0\n",
"Register worker succeeded\n",
"\n",
"Session id is: 3\n",
"Session token is: 071eec5b399e563de181c8e452d3f2973628d0c422e8083afa29d33c2b657529\n",
"Session id is: 11\n",
"Session token is: 07589d480e99cdb41bf26b263e236eae381f0ba33feec5054c62a38a3c41f811\n",
"\n",
"Send state for 25 times\n",
"Add senders succeeded.\n",
"\n",
"Get LB status succeeded: <e2sar_py.ControlPlane.LoadBalancerStatusReply object at 0x7f671b486ff0>\n",
"Get LB status succeeded: <e2sar_py.ControlPlane.LoadBalancerStatusReply object at 0x7fe9054f5170>\n",
"Remove senders succeeded.\n",
"\n",
"Get LB status succeeded: <e2sar_py.ControlPlane.LoadBalancerStatusReply object at 0x7f6740354130>\n",
"Get LB status succeeded: <e2sar_py.ControlPlane.LoadBalancerStatusReply object at 0x7fe905535430>\n",
"\n",
"Deregister worker succeeded\n",
"Free LB succeeded!\n"
Expand Down Expand Up @@ -1076,7 +1076,7 @@
},
{
"cell_type": "code",
"execution_count": 35,
"execution_count": 39,
"metadata": {},
"outputs": [
{
Expand All @@ -1086,25 +1086,26 @@
"Create LBManager obj succeeded: 0\n",
"Register worker succeeded\n",
"\n",
"Session id is: 4\n",
"Session token is: 33298a5893b6b5d9808f96ac351d0671886d1d7ad5693d9676f0401e1289fa14\n",
"Session id is: 14\n",
"Session token is: 24409feb705a6ae6a6ef7dce008a7c726fa6134bba00e19e47ca6d342d81d162\n",
"\n",
"Send state for 25 times\n",
"\n",
"Get LB status succeeded: <e2sar_py.ControlPlane.LoadBalancerStatusReply object at 0x7f671b4a16b0>\n",
"Get LB status succeeded: <e2sar_py.ControlPlane.LoadBalancerStatusReply object at 0x7fe9054d33b0>\n",
"Sender addresses: ['192.168.20.1', '192.168.20.2']\n",
"Current Epoch: 3\n",
"Current Epoch: 2\n",
"Current predicted Event No: 9223372036854775808\n",
"Workers: [<e2sar_py.ControlPlane.WorkerStatus object at 0x7f6740354130>]\n",
"Timestamp: seconds: 1726507812\n",
"nanos: 130294396\n",
"Workers: [<e2sar_py.ControlPlane.WorkerStatus object at 0x7fe8ed6b9830>]\n",
"Timestamp: seconds: 1726512975\n",
"nanos: 658369981\n",
"\n",
"expiresAt: seconds: 1726511409\n",
"expiresAt: seconds: 1726516573\n",
"\n",
"\n",
"Send state for 25 times\n",
"\n",
"LB id: 7\n"
"LB id: 23\n",
"1\n"
]
}
],
Expand Down Expand Up @@ -1203,12 +1204,12 @@
"print(\"LB id: \", res[0].lb_id)\n",
"assert(res[0].name == \"mylb\")\n",
"assert(res[0].lb_status.senderAddresses == ip_list)\n",
"# print(res[0].lb_status.workers, dir(res[0].lb_status.workers))"
"print(len(res[0].lb_status.workers))"
]
},
{
"cell_type": "code",
"execution_count": 36,
"execution_count": 40,
"metadata": {},
"outputs": [
{
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -1045,7 +1045,7 @@
"name": "python",
"nbconvert_exporter": "python",
"pygments_lexer": "ipython3",
"version": "3.11.9"
"version": "3.10.12"
}
},
"nbformat": 4,
Expand Down
Loading

0 comments on commit 351e7bf

Please sign in to comment.