Skip to content

Commit 85477f5

Browse files
Make the murfey client config file optional (#768)
The /home/.murfey file should no longer be needed, as it only records the server and instrument names. This PR removes the need for this file. - Adds a --server flag on instrument server startup to supply the backend url. - The need for the instrument name has been removed entirely. If the --server flag is not provided we fall back to the config file.
1 parent 7df6b28 commit 85477f5

File tree

18 files changed

+118
-41
lines changed

18 files changed

+118
-41
lines changed

src/murfey/client/context.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -201,6 +201,7 @@ def ensure_dcg_exists(
201201
router_name="workflow.router",
202202
function_name="register_dc_group",
203203
token=token,
204+
instrument_name=environment.instrument_name,
204205
visit_name=environment.visit,
205206
session_id=environment.murfey_session,
206207
data=dcg_data,

src/murfey/client/contexts/atlas.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -55,6 +55,7 @@ def post_transfer_serialem(
5555
router_name="session_control.spa_router",
5656
function_name="register_atlas",
5757
token=self._token,
58+
instrument_name=environment.instrument_name,
5859
session_id=environment.murfey_session,
5960
data={
6061
"name": transferred_file.stem,
@@ -85,6 +86,7 @@ def post_transfer_epu(
8586
router_name="session_control.spa_router",
8687
function_name="make_atlas_jpg",
8788
token=self._token,
89+
instrument_name=environment.instrument_name,
8890
session_id=environment.murfey_session,
8991
data={"path": str(transferred_atlas_name).replace("//", "/")},
9092
)
@@ -138,6 +140,7 @@ def post_transfer_epu(
138140
router_name="workflow.router",
139141
function_name="register_dc_group",
140142
token=self._token,
143+
instrument_name=environment.instrument_name,
141144
visit_name=environment.visit,
142145
session_id=environment.murfey_session,
143146
data=dcg_data,

src/murfey/client/contexts/clem.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -329,6 +329,7 @@ def process_lif_file(
329329
router_name="clem.router",
330330
function_name="process_raw_lifs",
331331
token=self._token,
332+
instrument_name=environment.instrument_name,
332333
session_id=environment.murfey_session,
333334
data={"lif_file": str(lif_file)},
334335
)
@@ -353,6 +354,7 @@ def process_tiff_series(
353354
router_name="clem.router",
354355
function_name="process_raw_tiffs",
355356
token=self._token,
357+
instrument_name=environment.instrument_name,
356358
session_id=environment.murfey_session,
357359
data=tiff_dataset,
358360
)

src/murfey/client/contexts/fib.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -237,6 +237,7 @@ def post_transfer(
237237
router_name="workflow.correlative_router",
238238
function_name="make_gif",
239239
token=self._token,
240+
instrument_name=environment.instrument_name,
240241
year=datetime.now().year,
241242
visit_name=environment.visit,
242243
session_id=environment.murfey_session,

src/murfey/client/contexts/spa.py

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -326,6 +326,7 @@ def _position_analysis(
326326
router_name="session_control.spa_router",
327327
function_name="register_grid_square",
328328
token=self._token,
329+
instrument_name=environment.instrument_name,
329330
session_id=environment.murfey_session,
330331
gsid=grid_square,
331332
data={
@@ -378,6 +379,7 @@ def _position_analysis(
378379
router_name="session_control.spa_router",
379380
function_name="register_foil_hole",
380381
token=self._token,
382+
instrument_name=environment.instrument_name,
381383
session_id=environment.murfey_session,
382384
gs_name=grid_square,
383385
data={
@@ -402,6 +404,7 @@ def _position_analysis(
402404
router_name="session_control.spa_router",
403405
function_name="register_foil_hole",
404406
token=self._token,
407+
instrument_name=environment.instrument_name,
405408
session_id=environment.murfey_session,
406409
gs_name=grid_square,
407410
data={
@@ -476,6 +479,7 @@ def post_transfer(
476479
router_name="file_io_instrument.router",
477480
function_name="write_eer_fractionation_file",
478481
token=self._token,
482+
instrument_name=environment.instrument_name,
479483
visit_name=environment.visit,
480484
session_id=environment.murfey_session,
481485
data={
@@ -539,6 +543,7 @@ def post_transfer(
539543
router_name="workflow.spa_router",
540544
function_name="request_spa_preprocessing",
541545
token=self._token,
546+
instrument_name=environment.instrument_name,
542547
visit_name=environment.visit,
543548
session_id=environment.murfey_session,
544549
data={

src/murfey/client/contexts/spa_metadata.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -138,6 +138,7 @@ def post_transfer(
138138
router_name="session_control.spa_router",
139139
function_name="register_grid_square",
140140
token=self._token,
141+
instrument_name=environment.instrument_name,
141142
session_id=environment.murfey_session,
142143
gsid=int(gs),
143144
data={
@@ -213,6 +214,7 @@ def post_transfer(
213214
router_name="session_control.spa_router",
214215
function_name="register_grid_square",
215216
token=self._token,
217+
instrument_name=environment.instrument_name,
216218
session_id=environment.murfey_session,
217219
gsid=gs_name,
218220
data={
@@ -232,6 +234,7 @@ def post_transfer(
232234
router_name="session_control.spa_router",
233235
function_name="register_foil_hole",
234236
token=self._token,
237+
instrument_name=environment.instrument_name,
235238
session_id=environment.murfey_session,
236239
gs_name=gs_name,
237240
data={

src/murfey/client/contexts/sxt.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -78,6 +78,7 @@ def register_sxt_data_collection(
7878
router_name="workflow.router",
7979
function_name="start_dc",
8080
token=self._token,
81+
instrument_name=environment.instrument_name,
8182
visit_name=environment.visit,
8283
session_id=environment.murfey_session,
8384
data=dc_data,
@@ -92,6 +93,7 @@ def register_sxt_data_collection(
9293
router_name="workflow.router",
9394
function_name="register_proc",
9495
token=self._token,
96+
instrument_name=environment.instrument_name,
9597
visit_name=environment.visit,
9698
session_id=environment.murfey_session,
9799
data={
@@ -221,6 +223,7 @@ def post_transfer(
221223
router_name="workflow.sxt_router",
222224
function_name="process_sxt_tilt_series",
223225
token=self._token,
226+
instrument_name=environment.instrument_name,
224227
visit_name=environment.visit,
225228
session_id=environment.murfey_session,
226229
data={

src/murfey/client/contexts/tomo.py

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -157,6 +157,7 @@ def register_tomography_data_collections(
157157
router_name="workflow.router",
158158
function_name="start_dc",
159159
token=self._token,
160+
instrument_name=environment.instrument_name,
160161
visit_name=environment.visit,
161162
session_id=environment.murfey_session,
162163
data=dc_data,
@@ -174,6 +175,7 @@ def register_tomography_data_collections(
174175
router_name="workflow.router",
175176
function_name="register_proc",
176177
token=self._token,
178+
instrument_name=environment.instrument_name,
177179
visit_name=environment.visit,
178180
session_id=environment.murfey_session,
179181
data={
@@ -290,6 +292,7 @@ def _add_tilt(
290292
router_name="workflow.tomo_router",
291293
function_name="register_tilt_series_for_rerun",
292294
token=self._token,
295+
instrument_name=environment.instrument_name,
293296
visit_name=environment.visit,
294297
data=rerun_data,
295298
)
@@ -310,6 +313,7 @@ def _add_tilt(
310313
router_name="workflow.tomo_router",
311314
function_name="register_tilt_series",
312315
token=self._token,
316+
instrument_name=environment.instrument_name,
313317
visit_name=environment.visit,
314318
data=ts_data,
315319
)
@@ -345,6 +349,7 @@ def _add_tilt(
345349
router_name="workflow.tomo_router",
346350
function_name="register_tilt",
347351
token=self._token,
352+
instrument_name=environment.instrument_name,
348353
visit_name=environment.visit,
349354
session_id=environment.murfey_session,
350355
data=tilt_data,
@@ -357,6 +362,7 @@ def _add_tilt(
357362
router_name="file_io_instrument.router",
358363
function_name="write_eer_fractionation_file",
359364
token=self._token,
365+
instrument_name=environment.instrument_name,
360366
visit_name=environment.visit,
361367
session_id=environment.murfey_session,
362368
data={
@@ -393,6 +399,7 @@ def _add_tilt(
393399
router_name="workflow.tomo_router",
394400
function_name="request_tomography_preprocessing",
395401
token=self._token,
402+
instrument_name=environment.instrument_name,
396403
visit_name=environment.visit,
397404
session_id=environment.murfey_session,
398405
data=preproc_data,
@@ -498,6 +505,7 @@ def post_transfer(
498505
router_name="workflow.tomo_router",
499506
function_name="register_tilt_series_length",
500507
token=self._token,
508+
instrument_name=environment.instrument_name,
501509
session_id=environment.murfey_session,
502510
data={
503511
"tags": [tilt_series],
@@ -518,6 +526,7 @@ def post_transfer(
518526
router_name="workflow.tomo_router",
519527
function_name="register_completed_tilt_series",
520528
token=self._token,
529+
instrument_name=environment.instrument_name,
521530
visit_name=environment.visit,
522531
session_id=environment.murfey_session,
523532
data={

src/murfey/client/contexts/tomo_metadata.py

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -155,6 +155,7 @@ def post_transfer(
155155
router_name="session_control.tomo_router",
156156
function_name="register_search_map",
157157
token=self._token,
158+
instrument_name=environment.instrument_name,
158159
session_id=environment.murfey_session,
159160
sm_name=transferred_file.parent.name,
160161
data={
@@ -213,6 +214,7 @@ def post_transfer(
213214
router_name="session_control.tomo_router",
214215
function_name="register_search_map",
215216
token=self._token,
217+
instrument_name=environment.instrument_name,
216218
session_id=environment.murfey_session,
217219
sm_name=transferred_file.parent.name,
218220
data={
@@ -266,6 +268,7 @@ def post_transfer(
266268
router_name="session_control.tomo_router",
267269
function_name="register_search_map",
268270
token=self._token,
271+
instrument_name=environment.instrument_name,
269272
session_id=environment.murfey_session,
270273
sm_name=search_map_name,
271274
data={
@@ -279,6 +282,7 @@ def post_transfer(
279282
router_name="session_control.tomo_router",
280283
function_name="register_batch_position",
281284
token=self._token,
285+
instrument_name=environment.instrument_name,
282286
session_id=environment.murfey_session,
283287
batch_name=batch_name,
284288
data={
@@ -309,6 +313,7 @@ def post_transfer(
309313
router_name="session_control.tomo_router",
310314
function_name="register_batch_position",
311315
token=self._token,
316+
instrument_name=environment.instrument_name,
312317
session_id=environment.murfey_session,
313318
batch_name=beamshift_name,
314319
data={

src/murfey/client/destinations.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -78,6 +78,7 @@ def determine_default_destination(
7878
router_name="file_io_instrument.router",
7979
function_name="suggest_path",
8080
token=token,
81+
instrument_name=environment.instrument_name,
8182
visit_name=visit,
8283
session_id=environment.murfey_session,
8384
data={

0 commit comments

Comments
 (0)