HKUBE local python api
api implementation for running and debugging Hkube`s pipeline without installing Hkube
prerequisite
- install hkubectl
# Check release page for latest version
os = "linux/macos/windows"
curl -Lo hkubectl https://github.com/kube-HPC/hkubectl/releases/latest/download/hkubectl-{linux/macos/windows} \
&& chmod +x hkubectl \
&& sudo mv hkubectl /usr/local/bin/
- run
pip install hkube.debbuging-python-api
usage
import asyncio
from hkube_debbuging_python_api.builder import Builder
def test1(data):
print(data['input'])
return data['input']
class runBuilder():
async def run():
build = Builder()
pipe = await build.createPipeline("test")
pipe.algorithm("test").input(5).add(test1).algorithm(
'test2').input("@test").input(8).add(test1).algorithm("test5").input("@test2").add(test2).flowInput().input({"david": 5}).add().execute()
bla = asyncio.run(runBuilder.run())
print('finish')
