save_to_df testing

2024-04-09 17:12:59 +05:30
parent f165f14af5
commit 5842aa0137
1 changed files with 2 additions and 2 deletions
@@ -69,8 +69,8 @@ def save_to_sf(dag_name, **kwargs):
    #     "{list(kwargs.keys())[1]}": "{list(kwargs.values())[1]}"
    #     }}"""

-    conf = f"""
-    {{ {json.dumps(kwargs)} 
+    conf = f"""{{
+    {json.dumps(kwargs)} 
    }}"""

    payload = mwaa_cli_command + " " + dag_name + " --conf '{}'".format(conf)