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
[BEAM-2718] Integrate bundle retry code for the DirectRunner #4113
[BEAM-2718] Integrate bundle retry code for the DirectRunner #4113
Conversation
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.
Thanks! This LGTM.
R: @chamikaramj for merge.
sdks/python/run_pylint.sh
Outdated
@@ -72,6 +72,7 @@ ISORT_EXCLUDED=( | |||
"iobase_test.py" | |||
"fast_coders_test.py" | |||
"slow_coders_test.py" | |||
"executor.py" |
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 is the problem with isort in this file?
59f2c74
to
580cbd8
Compare
580cbd8
to
907a7da
Compare
sdks/python/run_pylint.sh
Outdated
@@ -72,6 +72,7 @@ ISORT_EXCLUDED=( | |||
"iobase_test.py" | |||
"fast_coders_test.py" | |||
"slow_coders_test.py" | |||
"executor.py" |
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.
aaltay wrote:
What is the problem with isort in this file?
It was complaining about the wrong import order for some reason. I have tried again without and it works without excluding the file.
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.
Thanks, LGTM.
sdks/python/run_pylint.sh
Outdated
@@ -72,6 +72,7 @@ ISORT_EXCLUDED=( | |||
"iobase_test.py" | |||
"fast_coders_test.py" | |||
"slow_coders_test.py" | |||
"executor.py" |
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.
mariapython wrote:
It was complaining about the wrong import order for some reason. I have tried again without and it works without excluding the file.
Done.
When processing of a bundle fails, the bundle is retried.