cernops / dask-lxplus Goto Github PK
View Code? Open in Web Editor NEWDask-Jobqueue wrapper for the CERN HTCondor cluster
License: Other
Dask-Jobqueue wrapper for the CERN HTCondor cluster
License: Other
Hello, dask-lxplus developer teams.
I faced some errors due to "job_extra_directives".
I guess that the "job_extra_directives" is disappeared on current dask_jobqueue.
Here is an error log.
======================================================================
ERROR: test_job_script_docker (__main__.TestCluster)
----------------------------------------------------------------------
Traceback (most recent call last):
File "/cvmfs/sft.cern.ch/lcg/views/LCG_102/x86_64-centos9-gcc11-opt/lib/python3.9/site-packages/dask_jobqueue/core.py", line 558, in _dummy_job
return self.job_cls(
File "/afs/cern.ch/user/g/geonmo/.local/lib/python3.9/site-packages/dask_lxplus/cluster.py", line 86, in __init__
super().__init__(scheduler=scheduler, name=name, disk=disk, **base_class_kwargs)
File "/cvmfs/sft.cern.ch/lcg/views/LCG_102/x86_64-centos9-gcc11-opt/lib/python3.9/site-packages/dask_jobqueue/htcondor.py", line 45, in __init__
super().__init__(
TypeError: __init__() got an unexpected keyword argument 'job_extra_directives'
The above exception was the direct cause of the following exception:
Traceback (most recent call last):
File "/afs/cern.ch/user/g/geonmo/dask/test_cluster.py", line 53, in test_job_script_docker
with CernCluster(
File "/afs/cern.ch/user/g/geonmo/.local/lib/python3.9/site-packages/dask_lxplus/cluster.py", line 168, in __init__
super().__init__(**base_class_kwargs)
File "/cvmfs/sft.cern.ch/lcg/views/LCG_102/x86_64-centos9-gcc11-opt/lib/python3.9/site-packages/dask_jobqueue/core.py", line 529, in __init__
self._dummy_job # trigger property to ensure that the job is valid
File "/cvmfs/sft.cern.ch/lcg/views/LCG_102/x86_64-centos9-gcc11-opt/lib/python3.9/site-packages/dask_jobqueue/core.py", line 576, in _dummy_job
raise ValueError(
ValueError: Got unexpected keyword argument 'job_extra_directives'. Very likely this unexpected parameter was passed in "job_kwargs" in the CernCluster constructor:
job_kwargs={'cores': 4, 'processes': 2, 'memory': '2000MB', 'disk': '1000MB', 'job_extra_directives': {'transfer_output_files': '""', 'JobBatchName': '"dask-worker"', 'MY.Jobflavour': '"longlunch"', 'MY.IsDaskWorker': 'true', 'docker_image': '"dask-lxplus/lxdask-cc7:latest"', 'universe': 'docker'}, 'submit_command_extra': ['-spool'], 'worker_extra_args': ['--worker-port', '10000:10100'], 'config_name': 'cern', 'interface': None, 'protocol': 'tcp://', 'security': None}
Hello,
I am following a simple setup from https://batchdocs.web.cern.ch/specialpayload/dask.html
Namely,
. /cvmfs/sft.cern.ch/lcg/views/LCG_102/x86_64-centos7-gcc11-opt/setup.sh
pip3 install --user dask_lxplus
export PYTHONPATH=~/.local/lib/python3.9/site-packages:$PYTHONPATH
then run the example script provided on that page with python test_dask.py
I get this error:
from distributed.utils import tmpfile
Traceback (most recent call last):
File "/afs/cern.ch/work/a/andrey/dask-test/test_dask.py", line 4, in <module>
from dask_lxplus import HTCondorCluster
ImportError: cannot import name 'HTCondorCluster' from 'dask_lxplus' (/afs/cern.ch/user/a/andrey/.local/lib/python3.9/site-packages/dask_lxplus/__init__.py)
Any suggestions?
Dear cernops team,
I have already initiate LCG environment by the following:
. /cvmfs/sft.cern.ch/lcg/views/LCG_102/x86_64-centos7-gcc11-opt/setup.sh
However, I still got a Value Error when creating CernCluster. Since this is very small change (checking with /views/ vs /releases/), I suspect that there might be a minor change in the naming convention for python interpreter shipped with LCG.
ValueError Traceback (most recent call last)
/tmp/pinkaew/ipykernel_17698/608536250.py in <module>
3 import socket
4
----> 5 cluster = CernCluster(
6 cores = 1,
7 memory = '2000MB',
~/.local/lib/python3.9/site-packages/dask_lxplus/cluster.py in __init__(self, worker_image, image_type, container_runtime, gpus, batch_name, lcg, **base_class_kwargs)
150 if lcg:
151 if not re.match('^/cvmfs/sft(?:-nightlies)?.cern.ch/lcg/views/.+/python[2,3]?$', sys.executable):
--> 152 raise ValueError(f"You need to have loaded the LCG environment before running the python interpreter. Current interpreter: {sys.executable}")
153
154 base_class_kwargs = CernCluster._modify_kwargs(
ValueError: You need to have loaded the LCG environment before running the python interpreter. Current interpreter: /cvmfs/sft.cern.ch/lcg/releases/Python/3.9.12-9a1bc/x86_64-centos7-gcc11-opt/bin/python3
A declarative, efficient, and flexible JavaScript library for building user interfaces.
๐ Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
An Open Source Machine Learning Framework for Everyone
The Web framework for perfectionists with deadlines.
A PHP framework for web artisans
Bring data to life with SVG, Canvas and HTML. ๐๐๐
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
Some thing interesting about web. New door for the world.
A server is a program made to process requests and deliver data to clients.
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
Some thing interesting about visualization, use data art
Some thing interesting about game, make everyone happy.
We are working to build community through open source technology. NB: members must have two-factor auth.
Open source projects and samples from Microsoft.
Google โค๏ธ Open Source for everyone.
Alibaba Open Source for everyone
Data-Driven Documents codes.
China tencent open source team.