Fix pr comments

Author: Roman Snapko

packages/server/api/src/app/flows/flow-run/flow-run-service.ts

@@ -159,15 +159,10 @@ export const flowRunService = {
       } as Record<string, StepOutput>,
     };
 
-    const serializedLogs = await logSerializer.serialize({
-      executionState,
-    });
-
-    const logsFile = await fileService.save({
-      data: serializedLogs,
-      type: FileType.FLOW_RUN_LOG,
-      compression: FileCompression.GZIP,
+    const logsFileId = await updateLogs({
+      logsFileId: null,
       projectId,
+      executionState,
     });
 
     const failedRun = {
@@ -185,7 +180,7 @@ export const flowRunService = {
       tasks: 0,
       duration: 0,
       tags: [],
-      logsFileId: logsFile.id,
+      logsFileId,
     };
 
     await flowRunRepo().save(failedRun);

packages/server/worker/src/lib/trigger/hooks/extract-trigger-payload-hooks.ts

@@ -98,16 +98,13 @@ function handleFailureFlow(
 ): void {
   const engineController = engineApiService(engineToken);
 
-  let request = {
+  const request = {
     flowId: flowVersion.flowId,
     projectId,
     success,
+    ...(!success && failureDetails ? failureDetails : {}),
   } as UpdateFailureCountRequest;
 
-  if (!success && failureDetails) {
-    request = { ...request, ...failureDetails };
-  }
-
   rejectedPromiseHandler(engineController.updateFailureCount(request));
 }