diff --git a/backend/windmill-worker/src/python_executor.rs b/backend/windmill-worker/src/python_executor.rs index 092b10e2e6..f532036d99 100644 --- a/backend/windmill-worker/src/python_executor.rs +++ b/backend/windmill-worker/src/python_executor.rs @@ -240,18 +240,18 @@ pub async fn handle_python_job( .iter() .map(|x| match x.typ { windmill_parser::Typ::Bytes => { + let name = &x.name; format!( - "if \"{}\" in kwargs and kwargs[\"{}\"] is not None:\n \ - kwargs[\"{}\"] = base64.b64decode(kwargs[\"{}\"])\n", - x.name, x.name, x.name, x.name + "if \"{name}\" in kwargs and kwargs[\"{name}\"] is not None:\n \ + kwargs[\"{name}\"] = base64.b64decode(kwargs[\"{name}\"])\n", ) } windmill_parser::Typ::Datetime => { + let name = &x.name; format!( - "if \"{}\" in kwargs and kwargs[\"{}\"] is not None:\n \ - kwargs[\"{}\"] = datetime.strptime(kwargs[\"{}\"], \ + "if \"{name}\" in kwargs and kwargs[\"{name}\"] is not None:\n \ + kwargs[\"{name}\"] = datetime.strptime(kwargs[\"{name}\"], \ '%Y-%m-%dT%H:%M')\n", - x.name, x.name, x.name, x.name ) } _ => "".to_string(), @@ -308,8 +308,8 @@ from {module_dir_dot} import {last} as inner_script with open("args.json") as f: kwargs = json.load(f, strict=False) args = {{}} -{spread} {transforms} +{spread} for k, v in list(args.items()): if v == '': del args[k]