@@ -166,7 +166,7 @@ def switch_redis_proposal(
166166 proposal_number : int or str
167167 number of the desired proposal, e.g. `123456`
168168 beamline : str
169- normalized beamline acronym, case-insensitive, e.g. `SMI` or `sst `
169+ Beamline acronym, case-insensitive, e.g. `SMI` or `sst1 `
170170 username : str or None
171171 login name of the user assigned to the proposal; if None, current user will be kept
172172 prefix : str
@@ -179,11 +179,16 @@ def switch_redis_proposal(
179179 md : RedisJSONDict
180180 The updated redis dictionary.
181181 """
182- location = prefix if prefix else beamline
182+ normalized_beamlines = {
183+ "sst1" : "sst" ,
184+ "sst2" : "sst" ,
185+ }
186+ redis_beamline = normalized_beamlines .get (beamline .lower (), beamline )
187+ location = prefix if prefix else redis_beamline
183188 if redis_ssl :
184189 redis_client = open_redis_client (redis_ssl = redis_ssl , redis_prefix = location )
185190 else :
186- redis_url = f"info.{ beamline } .nsls2.bnl.gov"
191+ redis_url = f"info.{ redis_beamline } .nsls2.bnl.gov"
187192 redis_client = open_redis_client (redis_ssl = redis_ssl , redis_prefix = location , redis_url = redis_url )
188193 if verbose :
189194 print (f"Redis connection info: { redis_client .client ().connection } " )
@@ -246,14 +251,8 @@ def sync_experiment(proposal_number, beamline, verbose=False, prefix="", redis_s
246251 username = input ("Username : " )
247252 authenticate (username )
248253
249- normalized_beamlines = {
250- "sst1" : "sst" ,
251- "sst2" : "sst" ,
252- }
253- redis_beamline = normalized_beamlines .get (beamline .lower (), beamline )
254-
255254 md = switch_redis_proposal (
256- proposal_number , beamline = redis_beamline , username = username , prefix = prefix , redis_ssl = redis_ssl , verbose = verbose
255+ proposal_number , beamline = beamline , username = username , prefix = prefix , redis_ssl = redis_ssl , verbose = verbose
257256 )
258257
259258 if verbose :
0 commit comments