distributed task distribution framework
Project description
Fleet
Fleet is a generic distributed task distribution framework based on a distributed file system. Task distribution frameworks like Ray and Celery require network connections for communication, which makes them difficult to use in clusters with poor network conditions. Fleet is a distributed framework based on a shared file system, independent of any network communication, allowing for task distribution among nodes without any network connections.
Features
- Distributed task distribution based on a shared file system
- Supports dynamic scaling
- Supports worker node heartbeat
- Supports manager node restart
- Supports set timeout for each task
- Pure Python implementation
Install
pip install open-fleet
Usage
See more examples in ./examples.
# run_manager.py
from fleet.manager import Manager
from fleet.config.config import get_args
base_dir = "./share_dir"
def main():
job_list = [1,2,3,4]
args = get_args(f"--base_dir {base_dir}")
manager = Manager(args=args, job_list=job_list)
manager.run()
if __name__ == '__main__':
main()
# run_worker.py
from fleet.worker import Worker
from fleet.config.config import get_args
from run_manager import base_dir
def add_one(x, info):
return {"status": "success", "result": x + 1}
def main():
args = get_args(f"--base_dir {base_dir}")
worker = Worker(args=args, job_func=add_one)
worker.run()
if __name__ == '__main__':
main()
Project details
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
open_fleet-0.0.3.tar.gz
(14.2 kB
view hashes)
Built Distribution
open_fleet-0.0.3-py3-none-any.whl
(14.9 kB
view hashes)
Close
Hashes for open_fleet-0.0.3-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 4f4617ec50fc5db9ed4c022dd02c3f9e794cda25860fc623b1efb58da25aa252 |
|
MD5 | 716901b76f832154c2b7f56565a4ea85 |
|
BLAKE2b-256 | a666a3e9c48d222e00a78340340ccdd3c50ea544e36dd79457cdbeb27288d63f |