Upload 10 files

ExecuteCodeAtomicFlow.py

@@ -32,10 +32,7 @@ class ExecuteCodeAtomicFlow(InterpreterAtomicFlow):
             os.remove(file_location)
 
     def _open_file_and_wait_for_upd(self, file_location):
-        try:
-            process = subprocess.Popen(["code", file_location])
-        except Exception:
-            raise
+        process = subprocess.Popen(["code", "--wait", file_location])
         while True:
             if process.poll() is not None:
                 break
@@ -51,6 +48,5 @@ class ExecuteCodeAtomicFlow(InterpreterAtomicFlow):
         self._process_input_data(input_data)
         execution_output = self._call()
         self._delete_file(file_loc)
-        code_ran = input_data["code"].deepcopy()
-        response = {"interpreter_output": execution_output, "code_ran": code_ran}
+        response = {"interpreter_output": execution_output, "code_ran": input_data['code']}
         return response

RunCodeAskUserFlow.yaml

@@ -1,4 +1,12 @@
 _target_: Tachi67.RunCodeFlowModule.RunCodeAskUserFlow.instantiate_from_default_config
+
+input_interface:
+  - "interpreter_output"
+  - "code_ran"
+output_interface:
+  - "summary"
+  - "result"
+
 request_multi_line_input_flag: False
 end_of_input_string: EOI
 

RunCodeFileEditAtomicFlow.py

@@ -28,7 +28,7 @@ class RunCodeFileEditAtomicFlow(CodeFileEditAtomicFlow):
 
     def _generate_temp_file_location(self, code_lib_location, file_extension):
         directory = os.path.dirname(code_lib_location)
-        ret = os.path.join(directory, 'run_code_temp'+'.'+file_extension)
+        ret = os.path.join(directory, 'run_code_temp'+file_extension)
         return ret
 
     def _check_input(self, input_data: Dict[str, Any]):