ctx context.Context,
filter sqlplugin.ReplicationTasksRangeFilter,
return pdb.ExecContext(ctx,
rangeDeleteReplicationTaskQuery,
filter.ShardID,
filter.InclusiveMinTaskID,
filter.ExclusiveMaxTaskID,
)
}
// InsertIntoReplicationDLQTasks inserts one or more rows into replication_tasks_dlq table