mz_storage::source::mysqlFunction return_definite_error
Source async fn return_definite_error(
err: DefiniteError,
outputs: &[usize],
data_handle: &AsyncOutputHandle<GtidPartition, AccountedStackBuilder<CapacityContainerBuilder<StackWrapper<((usize, Result<SourceMessage, DataflowError>), GtidPartition, Diff)>>>, Tee<GtidPartition, StackWrapper<((usize, Result<SourceMessage, DataflowError>), GtidPartition, Diff)>>>,
data_cap_set: &CapabilitySet<GtidPartition>,
definite_error_handle: &AsyncOutputHandle<GtidPartition, CapacityContainerBuilder<Vec<ReplicationError>>, Tee<GtidPartition, Vec<ReplicationError>>>,
definite_error_cap_set: &CapabilitySet<GtidPartition>,
)