pydantic_action( reads=["foo", "bar"], writes=["baz", "qux"], state_input_type=StateMo

_call_execute_method_pre_post(ExecuteMethod.aiterate)

router.post("/answer_questions/{project_id}/{app_id}")

_call_execute_method_pre_post(ExecuteMethod.arun)

_call_execute_method_pre_post(ExecuteMethod.astep)

_call_execute_method_pre_post(ExecuteMethod.astream_iterate)

router.get("/history/{project_id}/{app_id}", response_model=List[ChatItem])

router.get("/response/{project_id}/{app_id}", response_model=List[ChatItem])

router.post("/response/{project_id}/{app_id}", response_class=StreamingResponse)

router.post("/response/{{project_id}}/{{app_id}}", response_model=List[ChatItem])

router.post("/count/{project_id}/{app_id}", response_model=CounterState)

ui_app.post( "/api/v0/{project_id}/{app_id}/{partition_key}/{sequence_id}/annotations", respon

app.post("/v1/chat/completions")

router.post("/create/{project_id}/{app_id}", response_model=str)

router.post("/create/{project_id}/{app_id}")

router.post("/create/{project_id}/{app_id}", response_model=str)

router.post("/create/{project_id}/{app_id}", response_model=str)

router.post("/create_new/{project_id}/{app_id}")

click.option( "--target-file-name", required=False, help="What file to write the data to. Else pri

action(reads=["diagnosis_outputs"], writes=["final_diagnosis"])

action(reads=["input_number"], writes=["current_number"])

action(reads=["input_number"], writes=["current_number"])

action(reads=["current_number"], writes=["output_number"])

action(reads=["current_number"], writes=["output_number"])

streaming_action.pydantic( reads=["count"], writes=["final_result"], state_output_type

action(reads=["query", "raw_response"], writes=["final_output"])

action(reads=["transcript"], writes=["post"])

action.pydantic(reads=["transcript"], writes=["post"])

streaming_action.pydantic( reads=["transcript"], writes=["post"], state_input_type=ApplicationStat

streaming_action.pydantic( reads=["transcript"], writes=["post"], state_input_type=ApplicationStat

ui_app.get("/api/v0/{project_id}/annotations", response_model=Sequence[AnnotationOut])

ui_app.get("/api/v0/metadata/app_spec", response_model=BackendSpec)

ui_app.get("/api/v0/{project_id}/{app_id}/{partition_key}/apps")

ui_app.get("/api/v0/{project_id}/{partition_key}/apps", response_model=ApplicationPage)

router.get("/state/{project_id}/{app_id}", response_model=CounterState)

ui_app.get("/api/v0/indexing_jobs", response_model=Sequence[IndexingJob])

ui_app.get("/api/v0/projects", response_model=Sequence[schema.Project])

router.get("/state/{project_id}/{app_id}")

action.pydantic( reads=["foo"], writes=["foo"], state_input_type=MyState, stat

router.post("/create/{project_id}/{app_id}")

ui_app.get("/ready")

_call_execute_method_pre_post(ExecuteMethod.iterate)

ui_app.get("/manifest.json")

action(reads=["input_variable"], writes=["output_variable"], tags=["tag1", "tag2"])

fire_and_forget

router.post("/provide_feedback/{project_id}/{app_id}")

ui_app.get("/{rest_of_path:path}")

ui_app.get("/api/v0/ready")

router.post("/response/{project_id}/{app_id}")

action(reads=["post"], writes=["post"])

app.get("/")

app.get("/")

action(reads=["db", "chat_history"], writes=["query", "route"])

_call_execute_method_pre_post(ExecuteMethod.run)

component.output_types(output_1=str, output_2=str)

action(reads=["db", "route", "lancedb_query", "docs_limit"], writes=["lancedb_results"])

singledispatch

action(reads=[], writes=["user_input"])

action(reads=["input_number", "number_to_add"], writes=["output_number"])

action(reads=["input_number", "number_to_add"], writes=["output_number"])

app.get("/social_media_post")

app.get("/social_media_post", response_model=SocialMediaPost)

app.get("/social_media_post_streaming", response_class=StreamingResponse)

app.get("/social_media_post_streaming_async", response_class=StreamingResponse)

_call_execute_method_pre_post(ExecuteMethod.step)

_call_execute_method_pre_post(ExecuteMethod.stream_iterate)

pytest.mark.parametrize( "input_string, on_windows, expected_result", [ ("Hello-World_123", Fa

action(reads=["input_variable"], writes=["output_variable"], tags=["tag1", "tag2"])

pytest.mark.file_name( "hypotheses_test_cases.json" ) # our fixture file with the expected inputs and out

pytest.mark.file_name( "e2e_test_cases.json" ) # our fixture file with the expected inputs and outputs

pytest.mark.parametrize( "input,hypothesis,expected", [ ("Patient exhibits mucus dripping from

ui_app.put( "/api/v0/{project_id}/{annotation_id}/update_annotations", response_model=Annotati

router.get("/validate")

router.get("/validate/{project_id}/{app_id}")

ui_app.get("/api/v0/version")