Fixing spark load

Yelp · Jul 18, 2023 · 8356392 · 8356392
1 parent 6bf359c
commit 8356392
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/paasta_tools/cli/cmds/spark_run.py b/paasta_tools/cli/cmds/spark_run.py
@@ -1203,7 +1203,7 @@ def paasta_spark_run(args):
         document = POD_TEMPLATE.format(
             spark_pod_label=limit_size_with_hash(f"exec-{app_base_name}"),
         )
-        parsed_pod_template = yaml.safe(document)
+        parsed_pod_template = yaml.load(document)
         with open(pod_template_path, "w") as f:
             yaml.dump(parsed_pod_template, f)