Skip to content

Commit

Permalink
MINOR: Fix ssl connection in usage & lineage (#16625)
Browse files Browse the repository at this point in the history
  • Loading branch information
ulixius9 authored and OnkarVO7 committed Jun 12, 2024
1 parent f244afc commit 95a51ab
Showing 1 changed file with 5 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -21,9 +21,10 @@
from metadata.generated.schema.type.tableQuery import TableQuery
from metadata.ingestion.api.steps import Source
from metadata.ingestion.ometa.ometa_api import OpenMetadata
from metadata.ingestion.source.connections import get_connection, get_test_connection_fn
from metadata.ingestion.source.connections import get_test_connection_fn
from metadata.utils.helpers import get_start_and_end
from metadata.utils.logger import ingestion_logger
from metadata.utils.ssl_manager import get_ssl_connection

logger = ingestion_logger()

Expand Down Expand Up @@ -55,7 +56,9 @@ def __init__(
self.service_connection = self.config.serviceConnection.__root__.config
self.source_config = self.config.sourceConfig.config
self.start, self.end = get_start_and_end(self.source_config.queryLogDuration)
self.engine = get_connection(self.service_connection) if get_engine else None
self.engine = (
get_ssl_connection(self.service_connection) if get_engine else None
)

@property
def name(self) -> str:
Expand Down

0 comments on commit 95a51ab

Please sign in to comment.