Skip to content

Commit

Permalink
Restore sleep
Browse files Browse the repository at this point in the history
  • Loading branch information
benmoriceau committed Oct 11, 2023
1 parent d7b525d commit aa431a7
Showing 1 changed file with 1 addition and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -393,6 +393,7 @@ private SerializedAirbyteMessageConsumer getStandardRecordConsumer(final BigQuer
},
(hasFailed) -> {
try {
Thread.sleep(30 * 1000);
typerDeduper.typeAndDedupe();
typerDeduper.commitFinalTables();
typerDeduper.cleanup();
Expand Down

0 comments on commit aa431a7

Please sign in to comment.