File tree Expand file tree Collapse file tree 1 file changed +13
-1
lines changed Expand file tree Collapse file tree 1 file changed +13
-1
lines changed Original file line number Diff line number Diff line change @@ -304,7 +304,19 @@ def ingest(
304304 """Ingest entities with optional request-level metadata."""
305305 for attempt in range (self ._max_auth_retries ):
306306 try :
307- request_metadata = convert_dict_to_struct (metadata ) if metadata else None
307+ request = ingester_pb2 .IngestRequest (
308+ stream = stream ,
309+ id = str (uuid .uuid4 ()),
310+ entities = entities ,
311+ sdk_name = self .name ,
312+ sdk_version = self .version ,
313+ producer_app_name = self .app_name ,
314+ producer_app_version = self .app_version ,
315+ )
316+ if metadata is not None :
317+ request_metadata = convert_dict_to_struct (metadata )
318+ request .metadata .CopyFrom (request_metadata )
319+ return self ._stub .Ingest (request , metadata = self ._metadata )
308320 request = ingester_pb2 .IngestRequest (
309321 stream = stream ,
310322 id = str (uuid .uuid4 ()),
You can’t perform that action at this time.
0 commit comments