fix(ingest): support async_flag properly in ingestProposalBatch (#12332)

datahub-project · Jan 14, 2025 · e1532a7 · e1532a7
1 parent ddd0d21
commit e1532a7
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/metadata-ingestion/src/datahub/emitter/rest_emitter.py b/metadata-ingestion/src/datahub/emitter/rest_emitter.py
@@ -374,7 +374,7 @@ def emit_mcps(
             # the size when chunking, and again for the actual request.
             payload_dict: dict = {"proposals": mcp_obj_chunk}
             if async_flag is not None:
-                payload_dict["async"] = True if async_flag else False
+                payload_dict["async"] = "true" if async_flag else "false"
 
             payload = json.dumps(payload_dict)
             self._emit_generic(url, payload)