-
Notifications
You must be signed in to change notification settings - Fork 21
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
feat: [FC-0074] add support for annotated python dicts as avro map type #433
base: main
Are you sure you want to change the base?
Conversation
Thanks for the pull request, @mariajgrimaldi! What's next?Please work through the following steps to get your changes ready for engineering review: 🔘 Get product approvalIf you haven't already, check this list to see if your contribution needs to go through the product review process.
🔘 Provide contextTo help your reviewers and other members of the community understand the purpose and larger context of your changes, feel free to add as much of the following information to the PR description as you can:
🔘 Get a green buildIf one or more checks are failing, continue working on your changes until this is no longer the case and your build turns green. 🔘 Let us know that your PR is ready for review:Who will review my changes?This repository is currently maintained by Where can I find more information?If you'd like to get more details on all aspects of the review process for open source pull requests (OSPRs), check out the following resources:
When can I expect my changes to be merged?Our goal is to get community contributions seen and reviewed as efficiently as possible. However, the amount of time that it takes to review and merge a PR can vary significantly based on factors such as:
💡 As a result it may take up to several weeks or months to complete a review and merge your PR. |
dict[str, str]: {'key': 'value'}, | ||
dict[str, int]: {'key': 1}, | ||
dict[str, float]: {'key': 1.0}, | ||
dict[str, bool]: {'key': True}, |
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.
what about union types:
dict[str, Union[str, int]]: ...,
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 added more test cases and this covers even more than I initially thought: a701f78. Thanks for the suggestion!
e71efcc
to
acdcaa9
Compare
# returns types of dict contents | ||
# if data_type == Dict[str, int], arg_data_type = (str, int) |
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.
nit: remove code comments
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 think that's commented code but an explanation of what arg_data_type is
) | ||
avro_type = SIMPLE_PYTHON_TYPE_TO_AVRO_MAPPING.get(arg_data_type[1]) | ||
if avro_type is None: | ||
raise TypeError( |
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 here
@@ -297,7 +297,7 @@ | |||
# .. event_data: DiscussionThreadData | |||
# .. event_warning: This event is currently incompatible with the event bus, list/dict cannot be serialized yet | |||
FORUM_THREAD_CREATED = OpenEdxPublicSignal( | |||
event_type="org.openedx.learning.thread.created.v1", | |||
event_type="org.openedx.learning.forum.thread.created.v1", |
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.
Does this need to be changed?
Should this emit a FORUM_THREAD_CREATED_V2
signal?
I imagine this will break existing code
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.
Oh yes, as I mentioned in the cover letter those changes are there for testing. That should be addressed in a follow up PR.
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.
Some nits and concerns around changing existing code and some code cleanup
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.
The tradeoff of supporting dicts only when annotated seems completely fair to me.
I agree that the refactoring of the forum events should go in a separate PR. Do you think this needs that we bump the versioning of the events or are they backwards compatible?
I do think it's backwards compatible. We'd be affecting the event bus support, which we didn't have previously, so I think we're okay. |
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 to me, but I haven't been in this code much so I'll refrain from thumbing it.
I'm tagging @robrap @timmc-edx for a review since they're more familiar with the event bus code. Can you help us out here? Do you think this looks reasonable? |
We're currently on break but should be able to review after Jan 6. |
Description
This PR supports Python dict types mapped to Avro Map type for avro schema generation, aiming to add support to a broader list of events payloads. This was previously attempted by mapping Python dicts -> records but this approach considers Python dicts -> maps to avoid conflicts with data attributes -> record mapping, also by using maps we avoid this kind of errors when we don't know the content of dictionaries:
This PR also refactors forum-related events so they can be sent through the event bus. Because of backward compatibility, those changes should be studied in a different PR but are here for testing simplicity.
Supporting information
This PR addresses #428 (comment)
Testing instructions
To test with the event bus:
You should see a log similar to this in the LMS:
Deadline
None
Other information
This was previously attempted here: but using record type instead of the map type: #232
Checklists
Check off if complete or not applicable:
Merge Checklist:
Post Merge:
finished.