Merge pull request #80 from amhsirak/develop

feat: additional run metadata

server/src/api/record.ts

@@ -222,6 +222,7 @@ async function createWorkflowAndStoreMetadata(id: string, userId: string) {
             interpreterSettings: { maxConcurrency: 1, maxRepeats: 1, debug: true },
             log: '',
             runId,
+            runByAPI: true,
             serializableOutput: {},
             binaryOutput: {},
         });

server/src/models/Run.ts

@@ -20,6 +20,9 @@ interface RunAttributes {
   interpreterSettings: InterpreterSettings;
   log: string;
   runId: string;
+  runByUserId?: string;
+  runByScheduleId?: string;
+  runByAPI?: boolean;
   serializableOutput: Record<string, any[]>;
   binaryOutput: Record<string, string>;
 }
@@ -38,6 +41,9 @@ class Run extends Model<RunAttributes, RunCreationAttributes> implements RunAttr
   public interpreterSettings!: InterpreterSettings;
   public log!: string;
   public runId!: string;
+  public runByUserId!: string;
+  public runByScheduleId!: string;
+  public runByAPI!: boolean;
   public serializableOutput!: Record<string, any[]>;
   public binaryOutput!: Record<string, any>;
 }
@@ -93,6 +99,18 @@ Run.init(
       type: DataTypes.UUID,
       allowNull: false,
     },
+    runByUserId: {
+      type: DataTypes.UUID,
+      allowNull: true,
+    },
+    runByScheduleId: {
+      type: DataTypes.UUID,
+      allowNull: true,
+    },
+    runByAPI: {
+      type: DataTypes.BOOLEAN,
+      allowNull: true,
+    },
     serializableOutput: {
       type: DataTypes.JSONB,
       allowNull: true,

server/src/routes/storage.ts

@@ -148,6 +148,7 @@ router.put('/runs/:id', requireSignIn, async (req, res) => {
       interpreterSettings: req.body,
       log: '',
       runId,
+      runByUserId: req.user.id,
       serializableOutput: {},
       binaryOutput: {},
     });

server/src/workflow-management/scheduler/index.ts

@@ -59,6 +59,7 @@ async function createWorkflowAndStoreMetadata(id: string, userId: string) {
       interpreterSettings: { maxConcurrency: 1, maxRepeats: 1, debug: true },
       log: '',
       runId,
+      runByScheduleId: uuid(),
       serializableOutput: {},
       binaryOutput: {},
     });