-
Notifications
You must be signed in to change notification settings - Fork 3k
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(elasticsearch): Updates to elasticsearch configuration, dao, tests #6269
feat(elasticsearch): Updates to elasticsearch configuration, dao, tests #6269
Conversation
d87a802
to
8f4e7bf
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.
Reviewed Internally. Looks good to me.
492ed0f
to
588d2a3
Compare
99c1b5d
to
32b81d1
Compare
11fd53f
to
d5568d9
Compare
f1d2c22
to
b8ef061
Compare
@@ -17,6 +17,7 @@ | |||
import pydantic | |||
import requests | |||
from expandvars import expandvars | |||
from requests_file import FileAdapter |
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 that intent here is to exercise the same logic that fetches compose files from github to be able to use file:// in the same way. There is logic in this class that is generally useful for running the smoke test locally.
...data-jobs/mae-consumer/src/main/java/com/linkedin/metadata/kafka/hook/UpdateIndicesHook.java
Outdated
Show resolved
Hide resolved
@@ -38,15 +38,22 @@ public class ElasticSearchBulkProcessorFactory { | |||
@Value("${elasticsearch.bulkProcessor.retryInterval}") | |||
private Long retryInterval; | |||
|
|||
@Value("#{new Boolean('${elasticsearch.bulkProcessor.async}')}") |
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 cause any weird behavior if there are typos/field missing? SPEL stuff can be a little wonky sometimes so this is usually better done in code IMO. I also thought it would auto try to coerce it to boolean without this, but that may also have wonkiness.
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 copied this from somewhere else in the code base. At one point I tried a few alternatives but they didn't seem to work so sticking with convention for this.
@@ -0,0 +1,28 @@ | |||
import requests |
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.
Rather than sprinkle sleep statements everywhere we wrap the requests library and sleep in a single place. There are now only a few places that are not using this injected requests wrapper.
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.
Love this!
b8ef061
to
3f8dbb7
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.
LGTM. This is a big PR so let's watch OSS closely after merging.
Great work, David!
f3e54cf
to
2dcac9d
Compare
2dcac9d
to
bec9354
Compare
Checklist