-
Notifications
You must be signed in to change notification settings - Fork 155
Refactor advanced subtensor #1756
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
base: main
Are you sure you want to change the base?
Conversation
3ce54c7 to
92f61ed
Compare
92f61ed to
a6cb68d
Compare
546100c to
4b02064
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This is looking pretty good.
Mostly I want to believe there is still room to simplify things / reuse code.
This is also a good opportunity to simplify the idx_list. There's no reason to use ScalarTypes in the dummy slices, and it's complicating our equality and hashing.
What about using simple integers to indicate what is the role of each index variable?
old_idx_list = (ps.int64, slice(ps.int64, None, None), ps.int64, slice(ps.int64, None, ps.int64))
new_idx_list = (0, slice(1, None, None), 2, slice(3, None, 4))Having the indices could probably come in handy anyway. With this we shouldn't need a custom hash / eq, we can just use the default one from __props__.
| else: | ||
| x, y, *idxs = node.inputs | ||
| x, y = node.inputs[0], node.inputs[1] | ||
| tensor_inputs = node.inputs[2:] |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I don't like the name tensor_inputs, x, y are also tensor and inputs. Use index_variables?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This applies elsewhere
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Using index_variables now.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Still using tensor_inputs in the last code you pushed
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Sorry about that, renamed now.
| # must already be raveled in the original graph, so we don't need to do anything to it | ||
| new_out = node.op(raveled_x, y, *new_idxs) | ||
| # But we must reshape the output to math the original shape | ||
| new_out = AdvancedIncSubtensor( |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
You should use type(op) so that subclasses are respected. It may also make sense to add a method to these indexing Ops like op.with_new_indices() that clones itself with a new idx_list. Maybe that will be the one that handles creating the new idx_list, instead of having to be here in the rewrite.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Currently functions ravel_multidimensional_bool_idx and ravel_multidimensional_bool_idx don't assume the subclass in the same way, but it'd be nice if you could check. Also, if I am giving up on some rewrites too quickly here, please let me know.
pytensor/tensor/subtensor.py
Outdated
| def __init__(self, idx_list): | ||
| """ | ||
| Initialize AdvancedSubtensor with index list. | ||
| Parameters | ||
| ---------- | ||
| idx_list : tuple | ||
| List of indices where slices are stored as-is, | ||
| and numerical indices are replaced by their types. | ||
| """ | ||
| self.idx_list = tuple( | ||
| index_vars_to_types(idx, allow_advanced=True) for idx in idx_list | ||
| ) | ||
| # Store expected number of tensor inputs for validation | ||
| self.expected_inputs_len = len( | ||
| get_slice_elements(self.idx_list, lambda entry: isinstance(entry, Type)) | ||
| ) | ||
|
|
||
| def __hash__(self): | ||
| msg = [] | ||
| for entry in self.idx_list: | ||
| if isinstance(entry, slice): | ||
| msg += [(entry.start, entry.stop, entry.step)] | ||
| else: | ||
| msg += [entry] | ||
|
|
||
| idx_list = tuple(msg) | ||
| return hash((type(self), idx_list)) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This already exists in Subtensor? If so create a BaseSubtensor class that handles idx_list and hash/equality based on it.
Make all Subtensor operations inherit from it
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Note this advice may make no sense if we simplify the idx_list to not need custom hash / eq
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
hash is a bit different based on whether it is *IncSubtensor or not in the current implementation. Wrote about the Python 3.11 slice not being hashable below.
| ) | ||
| else: | ||
| return vectorize_node_fallback(op, node, batch_x, *batch_idxs) | ||
| # With the new interface, all inputs are tensors, so Blockwise can handle them |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Comment should not mention a specific time period. Previous status is not relevant here
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Also we still want to avoid Blockwise eagerly if we can
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
All time periods should be removed from comments that were added in this PR.
pytensor/tensor/variable.py
Outdated
| pattern.append("x") | ||
| new_args.append(slice(None)) | ||
| else: | ||
| # Check for boolean index which consumes multiple dimensions |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This is probably right, but why does it matter that boolean indexing consumes multiple dimensions? Aren't we doing expand_dims where there was None -> replace new_axis by None slice -> index again?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
There might be a more dynamic approach, but I have had trouble with multidimensional bool arrays and ellipsis, e.g. x[multi_dim_bool_tensor,None,...] will not know where to add the new axis.
|
Just wanted to repeat, this is looking great. Thanks so far @jaanerik I'm being picky because indexing is a pretty fundamental operation, so want to make sure we get it right this time. |
@ricardoV94 I am struggling a bit with understanding your example, because old_idx_list also has ints. Could you clarify how you see constant index and variable index both working here. If you have the last slice of Absolutely no problem with being picky. I am very grateful for the feedback :) |
|
I updated it, it was some copy-paste typos. Old_idx doesn't have ints, only |
4787bc9 to
5ba887b
Compare
d821794 to
02a8d24
Compare
71aeef3 to
b5d5ffa
Compare
|
Taking a while with this, sorry. Finally simplified the idx_list. I'll note that Python |
e2af59e to
eafb683
Compare
Co-authored-by: ricardoV94 <[email protected]>
… handling Co-authored-by: ricardoV94 <[email protected]>
…ation Co-authored-by: ricardoV94 <[email protected]>
…ensor approach Co-authored-by: ricardoV94 <[email protected]>
… interface, store expected_inputs_len Co-authored-by: ricardoV94 <[email protected]>
eafb683 to
0be86da
Compare
0be86da to
e89da66
Compare
Description
Allows vectorizing AdvancedSetSubtensor.
Gemini picks up where Copilot left off.
Related Issue
Checklist
Type of change