field_validator("input_files", mode="before")

field_validator( "agents", mode="before", json_schema_input_type=_CrewAgentsInput,

field_validator("input", mode="before")

field_validator("inputs", mode="before")

router("parallel_todos_complete")

router(emit=["resume"])

router(diagnose_conditions)

ask_for_human_input.setter

router("auth")

router("continue_reasoning")

router("continue_reasoning_native")

router("exp")

router(or_(initialize_reasoning, continue_iteration))

router(mark_todo_complete)

router(execute_native_tool)

router(execute_tool_action)

router(generate_plan)

router(or_(begin, "capture"))

router(begin)

click.version_option(_get_cli_version())

router(cycle_entry)

router(init)

router(begin)

router(begin, emit=["go_left"])

router(process)

router(search_chunks)

router("step_observed_high")

router(emit=["continue"])

router(begin)

router(diagnose_conditions)

router(scan_medical)

router(begin)

router(begin)

router(event_b)

router(joined)

router("force_final_answer")

router(emit=["continue", "stop"])

crewai_event_bus.on(ToolValidateInputErrorEvent)

router("native_tool_calls")

router("single_todo_ready")

router("multiple_todos_ready")

router("execute_tool")

before_tool_call(tools=["delete_file", "execute_code"])

before_tool_call(tools=["delete_file"])

router(emit=["approved", "not_approved"])

router(emit=["approved", "not_approved"])

router("has_todos")

router("continue_plan")

router("goal_achieved")

listen("option_c") # This trigger is never output by any router

router("refine_and_continue")

router("needs_replan")

router("replan_now")

router("step_observed_low")

router("step_observed_medium")

router(diagnose_conditions)

router("todo_not_satisfied")

router(kick)

router(or_("todo_injected", "no_todos", "planning_disabled"))

input_provider.setter

router(begin)

router(handler)

router(method_2)

router(begin)

router("step_executed")

event_bus.on(ToolValidateInputErrorEvent)

tool("opaque", result_schema=OpaqueOutput)

field_validator("output_file")

router(re_search)

router("context_error")

router("parser_error")

click.option( "-k", "--kickoff-outputs", is_flag=True, help="Reset LATEST KICKOFF TASK OUTPUTS" )

human_feedback( message="Review this output.", emit=["done", "revise"], ll

router(begin)

router(begin, emit=["x", "y"])

router(call_llm_and_parse)

_conversation_start_router

router(begin)

router(init)

router(initial)

router(start_method)

router(start)

router(kick)

router(and_(handle_next_step_or_event, branch_2_step))

router("auth")

router("SignalA")

router(converge_and)

router(begin)

router(process_level_1)

router(process_level_2)

router(or_("step_a", "step_b"))

click.option( "--inputs", type=str, default=None, help='Flow-only: JSON object passed to the d

tool("search", result_schema=SearchOutput)

router(emit=["second_approval", "not_approved"])

router(emit=["second_approval", "not_approved"])

router(entrance)

patch.dict( "os.environ", {"BRIGHT_DATA_API_KEY": "test_api_key", "BRIGHT_DATA_ZONE": "test_zo

patch("crewai_core.token_manager.TokenManager._get_or_create_key")

patch("crewai_cli.command.get_auth_token")

patch("crewai_cli.command.get_auth_token")