yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-08-19 06:28:03 +00:00
Code Issues Packages Projects Releases Wiki Activity

MINOR: Athena & Tableau E2E fix (#18596)

Browse Source
This commit is contained in:
Mayur Singal 2024-11-12 19:14:45 +05:30 committed by GitHub
parent 70c7880dfa
commit f4fdafeb8a
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
ingestion/tests/cli_e2e/dashboard/tableau/tableau.yaml
View File

@ -11,7 +11,7 @@ source:
hostPort: $E2E_TABLEAU_HOST_PORT hostPort: $E2E_TABLEAU_HOST_PORT
siteName: $E2E_TABLEAU_SITE siteName: $E2E_TABLEAU_SITE
siteUrl: $E2E_TABLEAU_SITE siteUrl: $E2E_TABLEAU_SITE
apiVersion: "3.22" apiVersion: "3.24"
sourceConfig: sourceConfig:
config: config:
type: DashboardMetadata type: DashboardMetadata

10
ingestion/tests/cli_e2e/test_cli_athena.py
View File

@ -88,7 +88,7 @@ class AthenaCliTest(CliCommonDB.TestSuite):
@staticmethod @staticmethod
def expected_filtered_schema_includes() -> int: def expected_filtered_schema_includes() -> int:
return 6 return 8
@staticmethod @staticmethod
def expected_filtered_schema_excludes() -> int: def expected_filtered_schema_excludes() -> int:
@ -96,15 +96,15 @@ class AthenaCliTest(CliCommonDB.TestSuite):
@staticmethod @staticmethod
def expected_filtered_table_includes() -> int: def expected_filtered_table_includes() -> int:
return 8 return 10
@staticmethod @staticmethod
def expected_filtered_table_excludes() -> int: def expected_filtered_table_excludes() -> int:
return 8 return 10
@staticmethod @staticmethod
def expected_filtered_mix() -> int: def expected_filtered_mix() -> int:
return 8 return 10
def retrieve_lineage(self, entity_fqn: str) -> dict: def retrieve_lineage(self, entity_fqn: str) -> dict:
pass pass
@ -135,7 +135,7 @@ class AthenaCliTest(CliCommonDB.TestSuite):
) -> None: ) -> None:
self.assertEqual(len(source_status.failures), 0) self.assertEqual(len(source_status.failures), 0)
self.assertEqual(len(source_status.warnings), 0) self.assertEqual(len(source_status.warnings), 0)
self.assertEqual(len(source_status.filtered), 6) self.assertGreaterEqual(len(source_status.filtered), 6)
self.assertGreaterEqual( self.assertGreaterEqual(
len(source_status.records) + len(source_status.updated_records), len(source_status.records) + len(source_status.updated_records),
self.expected_tables(), self.expected_tables(),