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

…dataset (#4244)
datahub-project · Feb 24, 2022 · a394096 · a394096
1 parent 975b356
commit a394096
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,
                     )
                 ]