Skip to main content
A flow launched with Launch response runs through the following states: The Launch requires the following arguments:
  • request (fastAPI.Request)
  • entry_point (str or callable)
  • inputs (Any)
Example: The following example launches a CrewAI Crew in hymn.app with core.Launch. 
@app.enter(
        path="/", 
        model=hymn_model,
        summary="Hymn Creator",
        description="This agent creates a short hymn about a given topic of your choice using openai and crewai.",
        version="1.0.1",
        author="[email protected]",
        tags=["Test", "CrewAi"]
    )
async def enter(request: fastapi.Request, inputs: dict):
    topic = inputs.get("topic", "").strip()
    if not topic:
        raise core.InputsError(topic="Please give me a topic.")
    return core.Launch(request, "hymn.app:crew", inputs=inputs)

​
Events

In the lifetime of a flow execution the following events are tracked.
eventdescriptionmethodscreen
metaflow metadata and entry point information(internal)n/a
inputsuser input data(internal)Input
agentagent informationagent meta datan/a
debugdebug messagedebugLog
stdoutstdout informationprint, sys.stdoutLog
stderrstderr informationsys.stderrLog
statusflow status change(internal)n/a
errorerror information(internal)Output/Reasoning/Log
actionaction informationtool resultReasoning
resulttask result informationresultReasoning
finalfinal result informationfinal resultOuput
uploaduser file upload(internal)Reasoning
lockhuman intervention is requiredlockOutput
leasehuman input when locks are leasedleaseLog
Kodosumi provides a couple of helper methods to simplify emitting events:
  • tracer.debug(message: str) - emit debug plain text message
  • tracer.result(message: Any) - emit result object
  • tracer.action(message: Any) - emit action result object
  • tracer.markdown(message: str) - emit markdown result string
  • tracer.html(message: str) - emit HTML result string
  • tracer.text(message: str) - emit plain text result string
The corresponding synchronous methods are
  • tracer.debug_sync(message: str)
  • tracer.result_sync(message: Any)
  • tracer.action_sync(message: Any)
  • tracer.markdown_sync(message: str)
  • tracer.html_sync(message: str)
  • tracer.text_sync(message: str)