​
prefect.input.actions

​
Functions

​
ensure_flow_run_id 

ensure_flow_run_id(flow_run_id: Optional[UUID] = None) -> UUID

​
create_flow_run_input_from_model 

create_flow_run_input_from_model(key: str, model_instance: pydantic.BaseModel, flow_run_id: Optional[UUID] = None, sender: Optional[str] = None)

​
create_flow_run_input 

create_flow_run_input(client: 'PrefectClient', key: str, value: Any, flow_run_id: Optional[UUID] = None, sender: Optional[str] = None)
Create a new flow run input. The given value will be serialized to JSON and stored as a flow run input value. Args:
  • - key: the flow run input key
  • - value: the flow run input value
  • - flow_run_id: the, optional, flow run ID. If not given will default to pulling the flow run ID from the current context.

​
filter_flow_run_input 

filter_flow_run_input(client: 'PrefectClient', key_prefix: str, limit: int = 1, exclude_keys: Optional[Set[str]] = None, flow_run_id: Optional[UUID] = None)

​
read_flow_run_input 

read_flow_run_input(client: 'PrefectClient', key: str, flow_run_id: Optional[UUID] = None) -> Any
Read a flow run input. Args:
  • - key: the flow run input key
  • - flow_run_id: the flow run ID

​
delete_flow_run_input 

delete_flow_run_input(client: 'PrefectClient', key: str, flow_run_id: Optional[UUID] = None)
Delete a flow run input. Args:
  • - flow_run_id: the flow run ID
  • - key: the flow run input key