save_to_df testing

2024-04-09 16:49:51 +05:30
parent 380ea3b2f3
commit 23728a0adf
1 changed files with 3 additions and 4 deletions
@@ -68,11 +68,10 @@ def save_to_sf(dag_name, **kwargs):
        "{list(kwargs.keys())[0]}": "{list(kwargs.values())[0]}",
        "{list(kwargs.keys())[1]}": "{list(kwargs.values())[1]}"
        }}"""
-    st.write(conf)

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

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