agi_cluster API

Usage Example

Installation

---

Update

---

Distribute

import asyncio
from agi_cluster import AGI
from agi_env import AgiEnv

async def main():
    env = AgiEnv(install_type=1)
    res = await AGI.distribute('flight', env, verbose=True, 
                                scheduler=None, workers=None, data_source="file", path="/home/jpm/data/flight", files="*", nfile=1, nskip=0, nread=0, sampling_rate=1.0, datemin="2020-01-01", datemax="2021-01-01", output_format="parquet")
    print(res)
    return res

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

---

---

Run

---

import asyncio
from agi_cluster import AGI
from agi_env import AgiEnv

async def main():
    env = AgiEnv(install_type=1)
    res = await AGI.run('flight', env, mode=0, 
                        scheduler=None, workers=None, 
                        verbose=True, data_source="file", path="/home/jpm/data/flight", files="*", nfile=1, nskip=0, nread=0, sampling_rate=1.0, datemin="2020-01-01", datemax="2021-01-01", output_format="parquet")
    print(res)
    return res

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

---

Reference

---

---

---

---

---

---