|
from graph.build_graph import BuildGraph
|
|
from pipeline.engine import PipelineEngine
|
|
|
|
|
|
async def build_endpoint(spec, nodes, cluster, intelligence):
|
|
|
|
graph = BuildGraph(spec).generate()
|
|
|
|
engine = PipelineEngine(nodes, cluster, intelligence)
|
|
|
|
return await engine.run(graph)
|