save_to_df testing

2024-04-09 17:40:25 +05:30
parent 98fc6d27b1
commit 6d73faf2ae
1 changed files with 1 additions and 1 deletions
@@ -69,7 +69,7 @@ def save_to_sf(dag_name, **kwargs):
        "{list(kwargs.keys())[1]}": "{list(kwargs.values())[1]}"
        }}"""

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

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