Copy params so we don't modify the actual param dict in place

This commit is contained in:
Nate Coraor
2021-01-28 18:35:14 -05:00
parent 049d4a2599
commit a0499e383c
+1 -1
View File
@@ -371,7 +371,7 @@ class PulsarJobRunner(AsynchronousJobRunner):
metadata_directory = os.path.join(job_wrapper.working_directory, "metadata")
dest_params = job_destination.params
remote_pulsar_app_config = dest_params.get("pulsar_app_config", {})
remote_pulsar_app_config = dest_params.get("pulsar_app_config", {}).copy()
if "pulsar_app_config_path" in dest_params:
pulsar_app_config_path = dest_params["pulsar_app_config_path"]
with open(pulsar_app_config_path, "r") as fh: