Skip to content

Commit a9664e0

Browse files
authored
Merge pull request #241 from RobertSchaffer1/fix_beamline_endstation_sync
Fixes bug at opls
2 parents ac2dd38 + ecd9be9 commit a9664e0

File tree

2 files changed

+8
-3
lines changed

2 files changed

+8
-3
lines changed

nslsii/sync_experiment/sync_experiment.py

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -180,7 +180,11 @@ def switch_redis_proposal(
180180
The updated redis dictionary.
181181
"""
182182
location = prefix if prefix else beamline
183-
redis_client = open_redis_client(redis_ssl=redis_ssl, redis_prefix=location)
183+
if redis_ssl:
184+
redis_client = open_redis_client(redis_ssl=redis_ssl, redis_prefix=location)
185+
else:
186+
redis_url=f"info.{beamline}.nsls2.bnl.gov"
187+
redis_client = open_redis_client(redis_ssl=redis_ssl, redis_prefix=location, redis_url=redis_url)
184188
if verbose:
185189
print(f"Redis connection info: {redis_client.client().connection}")
186190
prefix = f"{prefix}-" if prefix and not redis_ssl else ""

nslsii/utils.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -51,8 +51,9 @@ def open_redis_client(
5151
"""
5252
Helper function to get the redis client connection.
5353
"""
54-
redis_url = os.getenv("REDIS_HOST", redis_url)
55-
if not redis_url:
54+
if os.getenv("REDIS_HOST"):
55+
redis_url = os.getenv("REDIS_HOST")
56+
if redis_url is None:
5657
if redis_ssl:
5758
client_loc_id = (
5859
redis_prefix if redis_prefix else socket.gethostname().split("-")[0]

0 commit comments

Comments
 (0)