-
Notifications
You must be signed in to change notification settings - Fork 587
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
Ingest 10K [VS-344] #7860
Ingest 10K [VS-344] #7860
Conversation
Codecov Report
@@ Coverage Diff @@
## ah_var_store #7860 +/- ##
================================================
Coverage ? 86.296%
Complexity ? 35197
================================================
Files ? 2170
Lines ? 164877
Branches ? 17783
================================================
Hits ? 142282
Misses ? 16271
Partials ? 6324 |
6b087a3
to
dbe9452
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.
a couple small nits but, essentially, 👍🏻
Co-authored-by: Bec Asch <[email protected]>
be8952d
to
85f9259
Compare
@@ -119,7 +119,9 @@ protected void writeJsonArray(int retryCount) throws ExecutionException, Interru | |||
} | |||
logger.warn("Caught exception writing to BigQuery, " + (maxRetries - retryCount - 1) + " retries remaining.", e); | |||
long backOffMillis = backoff.nextBackOffMillis(); | |||
logger.warn("Sleeping for {} milliseconds before retrying.", backOffMillis); |
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 did not know you could use the {} syntax in logger.
Setting a default batch size of 5 since that seemed to work out well in the two Stroke Anderson runs, overridable at the workflow level. Also cleaned up some logging and wrapping exceptions before throwing to avoid confusing stack traces when scanning through logs.