Skip to content

Commit

Permalink
Also clean up namespaces.
Browse files Browse the repository at this point in the history
  • Loading branch information
davinchia committed Aug 21, 2023
1 parent 6b0a276 commit ccc306b
Showing 1 changed file with 3 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -1082,12 +1082,13 @@ public void testNamespaces(final String testCaseId,
DataArgumentsProvider.NAMESPACE_CONFIG.getMessageFileVersion(getProtocolVersion())).lines()
.map(record -> Jsons.deserialize(record, AirbyteMessage.class))
.collect(Collectors.toList());
final List<AirbyteMessage> messagesWithNewNamespace = getRecordMessagesWithNewNamespace(
messages, namespace);
final List<AirbyteMessage> messagesWithNewNamespace = getRecordMessagesWithNewNamespace(messages, namespace);

final JsonNode config = getConfig();
try {
runSyncAndVerifyStateOutput(config, messagesWithNewNamespace, configuredCatalog, false);
// Add to the list of schemas to clean up.
TEST_SCHEMAS.add(namespace);
} catch (final Exception e) {
throw new IOException(String.format(
"[Test Case %s] Destination failed to sync data to namespace %s, see \"namespace_test_cases.json for details\"",
Expand Down

0 comments on commit ccc306b

Please sign in to comment.