fn determine_flow_type_for_source_state( flow_name: &str, flow_options: &HashMap<String, String>, has_missing_source_table: bool, has_instant_ttl_source_table: bool, force_batching: bool, ) -> Result<Option<FlowType>>