fix(ingest): kafka-connect - pass the env variable as part of making …

…dataset (datahub-project#4244)
maggiehays · Aug 1, 2022 · ef80378 · ef80378
1 parent f6a0f0a
commit ef80378
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/metadata-ingestion/src/datahub/ingestion/source/kafka_connect.py b/metadata-ingestion/src/datahub/ingestion/source/kafka_connect.py
@@ -891,6 +891,7 @@ def construct_job_workunits(
                             source_platform,
                             source_dataset,
                             platform_instance=source_platform_instance,
+                            env=self.config.env,
                         )
                     ]
                     if source_dataset
@@ -901,6 +902,7 @@ def construct_job_workunits(
                         target_platform,
                         target_dataset,
                         platform_instance=target_platform_instance,
+                        env=self.config.env,
                     )
                 ]