set default timeout

Author: david-leifker

metadata-ingestion/kafka_mces.json

@@ -0,0 +1,3 @@
+[
+
+]

metadata-ingestion/src/datahub/emitter/rest_emitter.py

@@ -428,7 +428,7 @@ def emit_mcp(
         mcp: Union[MetadataChangeProposal, MetadataChangeProposalWrapper],
         async_flag: Optional[bool] = None,
         trace_flag: Optional[bool] = None,
-        trace_timeout: Optional[timedelta] = None,
+        trace_timeout: Optional[timedelta] = timedelta(seconds=3600),
     ) -> None:
         ensure_has_system_metadata(mcp)
 
@@ -469,7 +469,7 @@ def emit_mcps(
         mcps: Sequence[Union[MetadataChangeProposal, MetadataChangeProposalWrapper]],
         async_flag: Optional[bool] = None,
         trace_flag: Optional[bool] = None,
-        trace_timeout: Optional[timedelta] = None,
+        trace_timeout: Optional[timedelta] = timedelta(seconds=3600),
     ) -> int:
         if _DATAHUB_EMITTER_TRACE:
             logger.debug(f"Attempting to emit MCP batch of size {len(mcps)}")
@@ -487,7 +487,7 @@ def _emit_openapi_mcps(
         mcps: Sequence[Union[MetadataChangeProposal, MetadataChangeProposalWrapper]],
         async_flag: Optional[bool] = None,
         trace_flag: Optional[bool] = None,
-        trace_timeout: Optional[timedelta] = None,
+        trace_timeout: Optional[timedelta] = timedelta(seconds=3600),
     ) -> int:
         """
         1. Grouping MCPs by their entity URL

metadata-ingestion/tests/test_helpers/graph_helpers.py

@@ -124,7 +124,7 @@ def emit_mcp(
         mcp: Union[MetadataChangeProposal, MetadataChangeProposalWrapper],
         async_flag: Optional[bool] = None,
         trace_flag: Optional[bool] = None,
-        trace_timeout: Optional[timedelta] = None,
+        trace_timeout: Optional[timedelta] = timedelta(seconds=3600),
     ) -> None:
         self.emitted.append(mcp)