-
Notifications
You must be signed in to change notification settings - Fork 4.1k
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
Measuring throughput of connectors #2605
Conversation
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.
lgtm.
worth noting that fetching the job output struck me that it could be dangerous because i didn't know what order saving the job output and doing the track calls happened. it looks like we do save job output before calling track so it should be okay.
airbyte-integrations/connectors/source-appsflyer-singer/unit_tests/unit_test.py
Outdated
Show resolved
Hide resolved
if (lastAttempt.getOutput() != null && lastAttempt.getOutput().isPresent()) { | ||
final JobOutput jobOutput = lastAttempt.getOutput().get(); | ||
final StandardSyncSummary syncSummary = jobOutput.getSync().getStandardSyncSummary(); | ||
metadata.put("duration", syncSummary.getEndTime() - syncSummary.getStartTime()); |
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.
just want to sanity check that sync summary metrics are in seconds?
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.
it's in milliseconds based on what's being saved in the syncSummary:
long startTime = System.currentTimeMillis(); |
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.
if you look at the excel spreadsheet that john put together for the tracking plan he is expecting seconds. either his expectation needs to change to ms or we need to convert here. i have no preference, just want to make sure that the two of you are speaking the same language.
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.
Ok will switch to seconds, thanks!
What
Closes #2524
How
Add attempts metadata when tracking job completions
Recommended reading order
airbyte-scheduler/src/main/java/io/airbyte/scheduler/JobTracker.java