ctx context.Context,
filter sqlplugin.ReplicationDLQTasksRangeFilter,
return mdb.ExecContext(ctx,
rangeDeleteReplicationTaskFromDLQQuery,
filter.SourceClusterName,
filter.ShardID,
filter.InclusiveMinTaskID,
filter.ExclusiveMaxTaskID,
)
}
// InsertIntoVisibilityTasks inserts one or more rows into visibility_tasks table