Skip to content

Commit 12ac854

Browse files
committed
Quick fix to test OD dask scaling
1 parent ac54fa4 commit 12ac854

1 file changed

Lines changed: 3 additions & 1 deletion

File tree

coffea_casa/coffea_casa.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -170,12 +170,14 @@ def _modify_job_kwargs(cls,
170170
input_files += [PIP_REQUIREMENTS]
171171
if CONDA_ENV.is_file():
172172
input_files += [CONDA_ENV]
173+
opendata = os.environ['OPENDATA_INSTANCE']
173174
# If we have certs in env, lets try to use TLS
174175
if (CA_FILE.is_file() and CERT_FILE.is_file() and cls.security().get_connection_args("scheduler")["require_encryption"]):
175176
job_config["protocol"] = "tls://"
176177
job_config["security"] = cls.security()
177178
input_files += [CA_FILE, CERT_FILE]
178-
XCACHE_SCITOKEN_FILE = bearer_token_path()
179+
if not opendata:
180+
XCACHE_SCITOKEN_FILE = bearer_token_path()
179181
if XCACHE_SCITOKEN_FILE:
180182
input_files += [XCACHE_SCITOKEN_FILE]
181183
else:

0 commit comments

Comments
 (0)