Skip to content

Commit 310e27e

Browse files
authored
feat(ingest): include endpoint in rest sink report (datahub-project#14272)
1 parent 1fd65d2 commit 310e27e

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

metadata-ingestion/src/datahub/ingestion/sink/datahub_rest.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -92,6 +92,7 @@ def validate_max_per_batch(cls, v):
9292
@dataclasses.dataclass
9393
class DataHubRestSinkReport(SinkReport):
9494
mode: Optional[RestSinkMode] = None
95+
endpoint: Optional[RestSinkEndpoint] = None
9596
max_threads: Optional[int] = None
9697
gms_version: Optional[str] = None
9798
pending_requests: int = 0
@@ -142,6 +143,7 @@ def __post_init__(self) -> None:
142143

143144
self.report.gms_version = gms_config.service_version
144145
self.report.mode = self.config.mode
146+
self.report.endpoint = self.config.endpoint
145147
self.report.max_threads = self.config.max_threads
146148
logger.debug("Setting env variables to override config")
147149
logger.debug("Setting gms config")

0 commit comments

Comments
 (0)