Module create_flow 

Modules

metadata 🔒

Structs

CreateFlowData

The serializable data.

CreateFlowProcedure

The procedure of flow creation.

Enums

CreateFlowState

The state of CreateFlowProcedure.

FlowType

The type of flow.

Constants

DEFER_ON_MISSING_SOURCE_KEY

The flow option key for creating pending flow metadata when source tables do not exist.

FLOW_EXPERIMENTAL_ENABLE_INCREMENTAL_READ_KEY

FLOW_SCHEDULED_TIME_MILLIS_EXTENSION_KEY 🔒

INTERNAL_EVAL_SCHEDULE_KEY

Internal transient key used to pass the serialized FlowScheduleConfig from meta to flownode through CreateRequest.flow_options. This key must never be accepted as a user-provided option and must never be persisted into FlowInfoValue.options. TODO(discord9): Replace this transient flow_options transport with a typed field in the flow create request.

Functions

ceil_to_boundary 🔒

Computes the ceiling of time to the next schedule boundary aligned with anchor + k * interval. All values are Unix timestamps in seconds.

defer_on_missing_source

effective_eval_schedule_from_flow_info

Returns the effective typed schedule config for flow metadata.

get_flow_type_from_options

resolve_schedule_defaults_into_task 🔒

Resolve FlowScheduleConfig into task.eval_schedule.

user_runtime_flow_options 🔒

validate_flow_options

without_scheduled_time_extension 🔒