jaketf commented on a change in pull request #11450:
URL: https://github.com/apache/beam/pull/11450#discussion_r413448804
##########
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:
Alternatively we could throw some EBO / retry logic waiting until the
list returns the number of messages we expect.
----------------------------------------------------------------
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]
