agi_distributor API

Usage Example

Installation

import asyncio
from agi_cluster.agi_distributor import AGI
from agi_env import AgiEnv, normalize_path
from pathlib import Path

async def main():
    app_env = AgiEnv(active_app=Path('/Users/jpm/agilab/src/agilab/apps/mycode_project') ,install_type=1, verbose=True)
    res = await AGI.install(app_env, modes_enabled=4,
                            scheduler="127.0.0.1", workers={'127.0.0.1': 2})
    print(res)
    return res

if __name__ == "__main__":
    asyncio.run(main())

---

import asyncio
from agi_cluster.agi_distributor import AGI
from agi_env import AgiEnv, normalize_path
from pathlib import Path

async def main():
    app_env = AgiEnv(active_app=Path('/Users/jpm/agilab/src/agilab/apps/flight_project') ,install_type=1, verbose=True)
    res = await AGI.install(app_env, modes_enabled=0,
                            scheduler=None, workers=None)
    print(res)
    return res

if __name__ == "__main__":
    asyncio.run(main())
            

---

Distribute

import asyncio
from agi_cluster.agi_distributor import AGI
from agi_env import AgiEnv, normalize_path
from pathlib import Path

async def main():
    app_env = AgiEnv(active_app=Path('/Users/jpm/agilab/src/agilab/apps/mycode_project'), install_type=1, verbose=True)
    res = await AGI.distribute(app_env,
                               cheduler="127.0.0.1", workers={'127.0.0.1': 2}, param1=0, param2="some text", param3=3.14, param4=True)
    print(res)
    return res

if __name__ == "__main__":
    asyncio.run(main())

---

import asyncio
from agi_cluster.agi_distributor import AGI
from agi_env import AgiEnv, normalize_path
from pathlib import Path

async def main():
    app_env = AgiEnv(active_app=Path('/Users/jpm/agilab/src/agilab/apps/flight_project'), install_type=1, verbose=True)
    res = await AGI.distribute(app_env,
                               scheduler=None, workers=None, data_source="file", path="data/flight/dataset", files="csv/*", nfile=2, nskip=0, nread=0, sampling_rate=1.0, datemin="2020-01-01", datemax="2021-01-01", output_format="csv")
    print(res)
    return res

if __name__ == "__main__":
    asyncio.run(main())

---

Run

import asyncio
from agi_cluster.agi_distributor import AGI
from agi_env import AgiEnv, normalize_path
from pathlib import Path

async def main():
    app_env = AgiEnv(active_app=Path('/Users/jpm/agilab/src/agilab/apps/mycode_project'), install_type=1, verbose=True) 
    res = await AGI.run(app_env, mode=4,
                        scheduler="127.0.0.1", workers={'127.0.0.1': 2}, 
                        param1=0, param2="some text", param3=3.14, param4=True)
    print(res)
    return res

if __name__ == "__main__":
    asyncio.get_event_loop().run_until_complete(main())
            

---

import asyncio
from agi_cluster.agi_distributor import AGI
from agi_env import AgiEnv, normalize_path
from pathlib import Path

async def main():
    app_env = AgiEnv(active_app=Path('/Users/jpm/agilab/src/agilab/apps/flight_project'), install_type=1, verbose=True) 
    res = await AGI.run(app_env, 
                        mode=0, 
                        scheduler=None, 
                        workers=None, 
                        data_source="file", path="data/flight/dataset", files="csv/*", nfile=2, nskip=0, nread=0, sampling_rate=1.0, datemin="2020-01-01", datemax="2021-01-01", output_format="csv")
    print(res)
    return res

if __name__ == "__main__":
    asyncio.get_event_loop().run_until_complete(main())
            

---

Reference

---

---

---