Module task

Modules§

BatchingExecutionGuard: Owns a whole serialized execution round. It may be moved to an execution collaborator, so cancellation of the caller cannot release the round early.
BatchingTask
ExecuteOnceOutcome
PlanInfo
TaskArgs: Arguments for creating batching task
TaskConfig: The task’s config, immutable once created

capture_recovery_batch_windows 🔒
determine_query_type 🔒
encode_insert_plan_request 🔒
format_insert_target_columns 🔒
initial_schedule_cursor 🔒: Initial scheduler cursor for start_scheduled_loop: exactly one interval before start_secs so the first due scheduled time is start_secs itself.
is_merge_mode_last_non_null 🔒
recovery_aggregate_input 🔒
scheduled_time_millis 🔒: Scheduled time in seconds converted to milliseconds for the FLOW_SCHEDULED_TIME_MILLIS extension.
sleep_delta_secs 🔒: Whole seconds to sleep until the next scheduled time next, measured from the current wall clock wall_now_secs.
wall_clock_unix_secs 🔒: Returns the current wall-clock Unix timestamp in seconds.