kafka-slurm-agent

View on PyPIReverse Dependencies (0)

1.3.0 kafka_slurm_agent-1.3.0-py3-none-any.whl

Wheel Details

Project: kafka-slurm-agent
Version: 1.3.0
Filename: kafka_slurm_agent-1.3.0-py3-none-any.whl
Download: [link]
Size: 31627
MD5: 3b307154979597315dd65043ca97c7a6
SHA256: 018eeaf7c1cdd38e875b4b27bd55c9f93cd1d3b441c706147f3dfb1f62299089
Uploaded: 2024-10-25 14:06:13 +0000

dist-info

METADATA

Metadata-Version: 2.1
Name: kafka_slurm_agent
Version: 1.3.0
Summary: The Kafka Slurm Agent is a distributed computing and stream processing engine that can be used to run python code acrossmultiple SLURM managed HPC clusters or individual workstations.It uses Kafka to asynchronously communicate with agents installed on clusters and workstations.It contains a monitoring tool with a Web JSON API and a job submitter.It is a pure Python implementation using faust stream processing
Author: Paweł Rubach
Author-Email: pawel.rubach[at]gmail.com
Home-Page: https://github.com/prubach/kafka-slurm-agent
Classifier: Programming Language :: Python :: 3
Classifier: Programming Language :: Python :: 3.6
Classifier: Programming Language :: Python :: 3.7
Classifier: Programming Language :: Python :: 3.8
Classifier: Programming Language :: Python :: 3.9
Classifier: Programming Language :: Python :: 3.10
Classifier: Programming Language :: Python :: 3.11
Classifier: Programming Language :: Python :: 3.12
Classifier: Programming Language :: Python :: 3.13
Classifier: License :: OSI Approved :: MIT License
Classifier: Operating System :: OS Independent
Requires-Python: >=3.6.0
Requires-Dist: simple-slurm
Requires-Dist: kafka-python-ng
Requires-Dist: psutil (>=5.6.6)
Requires-Dist: python-math
Requires-Dist: faust-streaming
Requires-Dist: werkzeug
Requires-Dist: wrapt-timeout-decorator
Description-Content-Type: text/markdown
License-File: LICENSE
[Description omitted; length: 3321 characters]

WHEEL

Wheel-Version: 1.0
Generator: skbuild 0.18.1
Root-Is-Purelib: true
Tag: py3-none-any

RECORD

Path Digest Size
kafka_slurm_agent/__init__.py sha256=Z443N5Cv9w8TrZFQ5WxjHvLpZBks7iokln6SLAsEk74 164
kafka_slurm_agent/cluster_agent.py sha256=EvRVobm7Rz2e42bxP8To366Y3jsTXSAkXNQNeeXLTB8 4150
kafka_slurm_agent/command.py sha256=lAFVoo1V15SdpBuLBac8mmTmILxfHV9oGxXw0rcLZJw 4929
kafka_slurm_agent/config_module.py sha256=1JnZTmvrj08tdprZROST7RkYp2UlCRL3CdgRre-mYKs 11318
kafka_slurm_agent/kafka_modules.py sha256=sZNicjm2wfiUPzzGKyGfeWgycnigd2Vcn2-daV0zoY4 27756
kafka_slurm_agent/monitor_agent.py sha256=UVAQqAJT8Cpzx1-V-mzXkTJ0vULOhzTL-7wIiKKAlPM 4686
kafka_slurm_agent/runner.py sha256=9Ne6b19Y7yQPYPlECJyYxcuDFXZutdzwUU91UeEsWdY 9000
kafka_slurm_agent/worker_agent.py sha256=qS4ymnvnfdLozzj88Wf3CV1IaAfmdulWGFZXJmrnEic 3463
kafka_slurm_agent-1.3.0.data/data/cluster_agent sha256=1tsn3OhOaReuH42EkkotbpO2TRjfiemKazr5g-c_JAE 2007
kafka_slurm_agent-1.3.0.data/data/kafkaslurm_cfg.py__ sha256=c2TIVTQX3YPimFiUcVSaLgPncpVM56J9UvxtTTyGUtc 2118
kafka_slurm_agent-1.3.0.data/data/monitor_agent sha256=nzf6GYqA45xaPkOSrMKLhZXLmqvrEPJ-lcgI_PRp1VQ 1991
kafka_slurm_agent-1.3.0.data/data/worker_agent sha256=s6mcqKJLJlSxclFzWv6FbnBRHQtYaNCOWotLaKQTG7o 2011
kafka_slurm_agent-1.3.0.dist-info/LICENSE sha256=xx0jnfkXJvxRnG63LTGOxlggYnIysveWIZ6H3PNdCrQ 11357
kafka_slurm_agent-1.3.0.dist-info/METADATA sha256=8NlAfWJMtcUP0Ud7b-UAhsZJ9N7yy530QunIhbNtQvY 4766
kafka_slurm_agent-1.3.0.dist-info/WHEEL sha256=m-nq1aIDeuxRdjfTNeALjyq_QDrHE03qCc8i5s_UmRs 86
kafka_slurm_agent-1.3.0.dist-info/entry_points.txt sha256=ZUA_WGaGq4I-RhntljmsmtHZMpbtuxXfWUgO0oxrqDE 61
kafka_slurm_agent-1.3.0.dist-info/top_level.txt sha256=ot5Idwc6vKowyJdvWhOZepKDqtzCTFN52Oe7iIrtfVQ 18
kafka_slurm_agent-1.3.0.dist-info/RECORD

top_level.txt

kafka_slurm_agent

entry_points.txt

kafka-slurm = kafka_slurm_agent.runner:run