Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

karabo-bridge-serve-run command #458

Merged
merged 13 commits into from
Nov 6, 2023
Merged

karabo-bridge-serve-run command #458

Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
13 commits
Select commit Hold shift + click to select a range
a0f059c
Split out serve_data function and show moree info while streaming
takluyver Oct 19, 2023
e97f0cb
Fix getting length of deque
takluyver Oct 19, 2023
2d4f64d
Print final update when streaming finishes
takluyver Oct 24, 2023
eae9935
Add karabo-bridge-serve-run command
takluyver Oct 24, 2023
0e3d0df
karabo-bridge-serve-run: only send complete trains by default
takluyver Oct 24, 2023
a67217f
Fix parameters to serve_data()
takluyver Oct 24, 2023
cda0b9c
Ensure print_update() can't have an undefined variable
takluyver Oct 25, 2023
73208fc
Make --port an option
takluyver Oct 30, 2023
10f145a
Document karabo-bridge-serve-run command
takluyver Nov 1, 2023
4554836
Add a test for karabo-bridge-serve-run
takluyver Nov 1, 2023
505aa3b
Simplify test
takluyver Nov 1, 2023
a46793d
Recreate raw+proc folder tree for each test using it
takluyver Nov 1, 2023
f15401c
Give test subprocesses a chance to exit cleanly
takluyver Nov 1, 2023
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion docs/aligning_trains.ipynb
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -849,7 +849,7 @@
],
"metadata": {
"kernelspec": {
"display_name": "xfel",
"display_name": "xfel (Python 3.7)",
"language": "python",
"name": "xfel"
},
Expand Down
2 changes: 1 addition & 1 deletion extra_data/export.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -189,7 +189,7 @@ def serve_data(data, port, append_detector_modules=False,
count += 1
new_time = time.monotonic()
if count % 5 == 0:
rate = len(deque) / (new_time - sent_times[0])
rate = len(sent_times) / (new_time - sent_times[0])
takluyver marked this conversation as resolved.
Show resolved Hide resolved
print(f'Sent {count}/{ntrains} trains - Train ID {tid} - {rate:.1f} Hz', end='\r')
sent_times.append(new_time)

Expand Down