-
Notifications
You must be signed in to change notification settings - Fork 496
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
Add masking strategies to message transforms #2284
base: main
Are you sure you want to change the base?
Add masking strategies to message transforms #2284
Conversation
🔗 Helpful Links🧪 See artifacts and rendered test results at hud.pytorch.org/pr/pytorch/torchtune/2284
Note: Links to docs will display an error until the docs builds have been completed. ❌ 5 New Failures, 4 Cancelled JobsAs of commit 4e97a57 with merge base 779569e (): NEW FAILURES - The following jobs have failed:
CANCELLED JOBS - The following jobs were cancelled. Please retry:
This comment was automatically generated by Dr. CI and updates every 15 minutes. |
db9a565
to
255bdcd
Compare
255bdcd
to
ac6272f
Compare
@RdoubleA Added |
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 looks great, really like the tests 👌 left a couple of comments
@@ -176,12 +185,24 @@ class InputOutputToMessages(Transform): | |||
|
|||
def __init__( | |||
self, | |||
train_on_input: bool = False, | |||
masking_strategy: Optional[str] = "train_on_all", |
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.
if the default value for train_on_input
was False, this would correspond to train_on_assistant
. Let's keep that same default behavior.
@@ -305,11 +332,23 @@ class ChosenRejectedToMessages(Transform): | |||
|
|||
def __init__( | |||
self, | |||
train_on_input: bool = False, | |||
masking_strategy: Optional[str] = "train_on_all", |
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.
same comment here
|
||
Raises: | ||
ValueError: If ``column_map`` is provided and ``conversations`` not in ``column_map``. | ||
""" | ||
|
||
def __init__( | ||
self, | ||
train_on_input: bool = False, | ||
masking_strategy: Optional[str] = "train_on_all", |
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.
same comment here
return {"messages": updated_messages} | ||
|
||
|
||
def validate_messages( |
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.
not sure if this is still used but let's keep this here for now
""" | ||
|
||
def __init__( | ||
self, train_on_input: bool = True, column_map: Optional[Dict[str, str]] = None | ||
self, | ||
masking_strategy: Optional[str] = "train_on_all", |
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.
contrary to the other comment, this default value should remain train_on_all
since train_on_input
was defaulted to True. so let's keep this
ValueError: If the masking strategy is not one of the supported strategies: | ||
`train_on_all`, `train_on_assistant`, `train_on_last`. | ||
""" | ||
if masking_strategy not in ["train_on_all", "train_on_assistant", "train_on_last"]: |
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.
One suggestion that I didn't mention in the issue is that we could make masking_strategy
an Enum so that it can be type checked more easily. users can still specify as a string in the config and in the message transforms above, but here in mask_messages
you could convert to the Enum, and the ValueError will automatically be captured.
Context
What is the purpose of this PR? Is it to
Please link to any issues this PR addresses.
#2261
Changelog
What are the changes made in this PR?
mask_messages
utility intorchtune/data/_messages.py
to mask each message given a list of messages based on user provided masking_strategyTest plan
Please make sure to do each of the following if applicable to your PR. If you're unsure about any one of these just ask and we will happily help. We also have a contributing page for some guidance on contributing.
pre-commit install
)pytest tests
pytest tests -m integration_test
UX
If your function changed a public API, please add a dummy example of what the user experience will look like when calling it.
Here is a docstring example
and a tutorial example