Launches a Dask Gateway cluster in K8s and joins HTCondor workers to it
Project description
HTCdaskGateway
- A Dask Gateway client extension for heterogeneous cluster mode combining the Kubernetes backend for pain-free scheduler networking, with COFFEA-powered HTCondor workers and/or OKD [coming soon].
- Latest is installed by default and deployed to the COFFEA-DASK notebook on EAF (https://analytics-hub.fnal.gov). A few lines will get you going!
- The current image for workers/schedulers is: coffeateam/coffea-dask-cc7-gateway:0.7.12-fastjet-3.3.4.0rc9-g8a990fa
Basic usage @ Fermilab EAF
- Make sure the notebook launched supports this functionality (COFFEA-DASK notebook)
from htcdaskgateway import HTCGateway
gateway = HTCGateway()
cluster = gateway.new_cluster()
# Scale my cluster to 5 HTCondor workers
cluster.scale(5)
# Obtain a client for connecting to your cluster scheduler
# Your cluster should be ready to take requests
client = cluster.get_client()
client
# When computations are finished, shutdown the cluster
cluster.shutdown()
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
htcdaskgateway-0.1.4.tar.gz
(5.8 kB
view hashes)
Built Distribution
Close
Hashes for htcdaskgateway-0.1.4-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 369d2605ab013ce38e0fdb9e45019dc0bf9a5727cc28a19b66bba0ea3843d43d |
|
MD5 | c90fd1beb0e84285d59b84ddcc436026 |
|
BLAKE2b-256 | 213460020bf791263ee9483f739f957e39dbc92257912b6b760386fd9044c675 |