fix: err.log when create container failed

eesast · May 9, 2024 · 5711cbe · 5711cbe
1 parent db04566
commit 5711cbe
Showing 1 changed file with 9 additions and 5 deletions.
diff --git a/src/helpers/docker_queue.ts b/src/helpers/docker_queue.ts
@@ -50,7 +50,7 @@ const upload_contest_files = async (sub_base_dir: string, queue_front: queue_ele
       const file_name = await fs_promises.readdir(`${sub_base_dir}/${queue_front.room_id}/output`);
       const upload_file_promises = file_name.map(filename => {
         console.log("filename: " + filename);
-        const key = `${contest_name}/arena/${queue_front.room_id}/${filename}`;
+        const key = `${contest_name}/${queue_front.competition?"competition":"arena"}/${queue_front.room_id}/${filename}`;
         const localFilePath = `${sub_base_dir}/${queue_front.room_id}/output/${filename}`;
         return utils.uploadObject(localFilePath, key, cos, config)
           .then(() => {
@@ -356,19 +356,23 @@ const docker_cron = async () => {
             }
           });
 
-        } catch (err) {
+        } catch (err: any) {
           console.error("An error occurred in creating containers:", err);
           new_containers.forEach(async (container) => {
             try {
               console.log("Removing container: " + container.id);
               container.remove({
                 force: true
               });
-            } catch (err) {
-              console.error("An error occurred in removing containers:", err);
+            } catch (err: any) {
+              if (err.statusCode !== 404)
+                console.error("An error occurred in removing containers:", err);
             }
           });
-          await hasura.update_room_status_and_port(queue_front.room_id, "Crashed", null);
+          fs.mkdirSync(`${sub_base_dir}/${queue_front.room_id}/output`, { recursive: true });
+          fs.writeFileSync(`${sub_base_dir}/${queue_front.room_id}/output/error.log`, err.message);
+          upload_contest_files(sub_base_dir, queue_front);
+          hasura.update_room_status_and_port(queue_front.room_id, "Failed", null);
           return;
         }