Skip to content
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 support for using Registry's via tuple #239

Merged
merged 4 commits into from
Jun 1, 2021
Merged

Conversation

acco
Copy link
Contributor

@acco acco commented May 30, 2021

Support overriding process_name/2 in Broadway module so that all processes in topology can be started with a via tuple.

Discussed in #236

test/broadway_test.exs Outdated Show resolved Hide resolved
test/broadway_test.exs Outdated Show resolved Hide resolved
test/broadway_test.exs Outdated Show resolved Hide resolved
@acco acco force-pushed the master branch 2 times, most recently from a55a5b1 to c5158f0 Compare May 30, 2021 17:06
@josevalim
Copy link
Member

Great work! I have added some minor comments.

We also need to add tests for Broadway.get_rate_limiting, Broadway.test_messages, Broadway.producer_names, and Broadway.topology. So I think we should move the test that we have so far into its own describe block, so we can add these new tests. WDYT?

lib/broadway/options.ex Outdated Show resolved Hide resolved
lib/broadway/options.ex Show resolved Hide resolved
lib/broadway/topology.ex Show resolved Hide resolved
lib/broadway/topology/rate_limiter.ex Outdated Show resolved Hide resolved
@acco
Copy link
Contributor Author

acco commented May 30, 2021

Sounds good @josevalim ! Updates coming, thanks so much for your quick feedback

Copy link
Contributor Author

@acco acco left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Alright @josevalim see updates!

Assuming we're getting close, let me know where in docs I can make updates

lib/broadway.ex Outdated Show resolved Hide resolved
lib/broadway/topology.ex Show resolved Hide resolved
lib/broadway/topology.ex Show resolved Hide resolved
lib/broadway/topology/producer_stage.ex Show resolved Hide resolved
lib/broadway/topology/rate_limiter.ex Show resolved Hide resolved
test/broadway_test.exs Show resolved Hide resolved
@acco acco requested a review from josevalim May 30, 2021 19:07
lib/broadway.ex Outdated Show resolved Hide resolved
lib/broadway.ex Outdated Show resolved Hide resolved
lib/broadway/options.ex Outdated Show resolved Hide resolved
lib/broadway/options.ex Outdated Show resolved Hide resolved
lib/broadway/topology.ex Outdated Show resolved Hide resolved
test/broadway_test.exs Outdated Show resolved Hide resolved
@josevalim
Copy link
Member

@acco fantastic! I have dropped the last batch of comments. Then please rebase and we should be good to go!

acco added 3 commits May 31, 2021 20:45
Support overriding process_name/2 in Broadway module so that all processes in topology can be started with a via tuple.
@acco
Copy link
Contributor Author

acco commented Jun 1, 2021

Thanks @josevalim, great notes! Just incorporated, rebased, and pushed. Assuming latest looks good, I can squash and we can merge. Let me know if it needs any other tweaks

lib/broadway.ex Outdated Show resolved Hide resolved
lib/broadway.ex Outdated Show resolved Hide resolved
lib/broadway/options.ex Outdated Show resolved Hide resolved
lib/broadway.ex Outdated Show resolved Hide resolved
lib/broadway.ex Outdated Show resolved Hide resolved
@josevalim
Copy link
Member

@acco I added some very minor comments and @whatyouhide suggested a guard, which can be very helpful, and we can ship it!

@acco acco requested a review from josevalim June 1, 2021 17:22
@acco
Copy link
Contributor Author

acco commented Jun 1, 2021

Great feedback/tweaks @josevalim @whatyouhide , thank you! Pushed latest. Happy to squash before merge, lmk

@josevalim josevalim merged commit 5174ff0 into dashbitco:master Jun 1, 2021
@josevalim
Copy link
Member

💚 💙 💜 💛 ❤️

@acco
Copy link
Contributor Author

acco commented Jun 1, 2021

Wooo! Thanks for all your help 🙏

whatyouhide added a commit that referenced this pull request Feb 8, 2022
It seems like this callback was accidentally generated inside the module
calling "use Broadway" instead of being part of the Broadway behaviour.

This callback was originally introduced in
#239.
whatyouhide added a commit that referenced this pull request Feb 8, 2022
It seems like this callback was accidentally generated inside the module
calling "use Broadway" instead of being part of the Broadway behaviour.

This callback was originally introduced in
#239.
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

None yet

3 participants