-
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
🎉 Google Analytics connector is failing #3648
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
@@ -59,19 +61,26 @@ def _validate_custom_reports(self, custom_reports_data: List[dict]): | |||
error_messages.append(error.message) | |||
raise Exception("An error occurred during custom_reports data validation: " + "; ".join(error_messages)) | |||
|
|||
def read_catalog(self, catalog_path: str) -> ConfiguredAirbyteCatalog: |
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.
this method is not called anywhere?
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 is called when performing read operation, I redefined this function from a base class to save and then filter out streams we want to use
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.
@po3na4skld, This method is called during the Read method, and when the Discover method is launched, no one stream will found, so we will get zero streams and we will not be able to read the data.
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 got it
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.
@yevhenii-ldv for now it works as before
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.
See above in comments
def _get_reports_file_path(self, temp_dir: str, custom_reports_data: List[dict]) -> str: | ||
report_definition = ( | ||
json.loads(pkgutil.get_data("tap_google_analytics", "defaults/default_report_definition.json")) + custom_reports_data | ||
) | ||
if self.reports_to_read is not None: |
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 self.reports_to_read
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, one small comment
@po3na4skld I see some strange files in PR that don't belong here, could you please merge with master and ensure there are no extra files. |
I think it is because I did chmod 777 on airbyte folder and after gradlew format they were added to the commits @keu you can see that there are not actual changes to these files. Merged master in this branch |
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.
please use this snippet to rollback changes
https://gist.github.com/liitfr/86c77bf0ea4a627ab9b62ad30c32c251
@davinchia |
thanks @po3na4skld @sherifnada is this related to #3958? Have we tried getting our limit increased? |
@davinchia As I know for now we disabled any GA testing when merging to master in order to keep rate limit on an acceptable level for testing this PR |
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.
@po3na4skld thanks for adding the test!
since we can't test this; I think it's fine to merge if you feel confident about it. we should make sure we eventually come back and turn it the tests on so we have confidence things are working well.
/test connector=source-googleanalytics-singer
|
airbyte-integrations/connectors/source-googleanalytics-singer/build.gradle
Show resolved
Hide resolved
/publish connector=connectors/source-googleanalytics-singer
|
/test connector=connectors/source-googleanalytics-singer
|
/publish connector=connectors/source-googleanalytics-singer
|
He passed it to another person: davinchia
What
It solves #3355.
How
Added filter into the GoogleAnalyticsSingerSource._get_reports_file_path so that it could remove non used in catalog provided by user. Also removed duplicated "title" key in spec.json file.
Pre-merge Checklist
Recommended reading order