jaketf commented on a change in pull request #11450:
URL: https://github.com/apache/beam/pull/11450#discussion_r414837666
##########
File path:
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/healthcare/HL7v2IOTestUtil.java
##########
@@ -91,10 +92,13 @@ static void deleteAllHL7v2Messages(HealthcareApiClient
client, String hl7v2Store
}
/** Populate the test messages into the HL7v2 store. */
- static void writeHL7v2Messages(HealthcareApiClient client, String
hl7v2Store) throws IOException {
+ static void writeHL7v2Messages(HealthcareApiClient client, String hl7v2Store)
+ throws IOException, InterruptedException {
for (HL7v2Message msg : MESSAGES) {
client.createHL7v2Message(hl7v2Store, msg.toModel());
}
+ // [BEAM-9779] HL7v2 indexing is asyncronous. Add sleep to stabilize this
IT.
+ Sleeper.DEFAULT.sleep(5000);
Review comment:
Based on internal thread it seems HCAPI team uses EBO w/ 10 min timeout
to deal with async indexing in their own integration tests. I've added the same
here.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
