search

cylondata / twister2

A composable framework for fast and scalable data analytics
https://twister2.org
Apache License 2.0
57 stars 32 forks source link

Exposing peers to the python env #919

Closed chathurawidanage closed 4 years ago

chathurawidanage commented 4 years ago 
from twister2.Twister2Environment import Twister2Environment

env = Twister2Environment(resources=[{"cpu": 4, "ram": 512, "instances": 4}])

prs = env.peers()
print(prs)
[2020-07-02 19:54:52 -0400] [INFO] [worker-3] [python-process] edu.iu.dsc.tws.python.PythonWorker: {0: '127.0.0.1', 1: '127.0.0.1', 2: '127.0.0.1', 3: '127.0.0.1'}