feat: keep track of multiple tasks (#3330)

Author: drdelambre

cypress/e2e/shared/dashboardsView.test.ts

@@ -105,9 +105,10 @@ describe('Dashboard', () => {
 
     cy.getByTestID('add-note--button').click()
     cy.getByTestID('note-editor--overlay').within(() => {
-      cy.getByTestID('markdown-editor').within(() => {
-        cy.get('textarea').type(`${headerPrefix} ${noteText}`, {force: true})
-      })
+      cy.get('.monaco-editor .view-line:last')
+        .click({force: true})
+        .focused()
+        .type(`${headerPrefix} ${noteText}`, {force: true, delay: 1})
 
       cy.getByTestID('note-editor--preview').contains(noteText)
       cy.getByTestID('note-editor--preview').should('not.contain', headerPrefix)
@@ -169,11 +170,10 @@ describe('Dashboard', () => {
     const headerPrefix2 = '-'
 
     cy.getByTestID('note-editor--overlay').within(() => {
-      cy.getByTestID('markdown-editor').within(() => {
-        cy.get('textarea')
-          .clear({force: true})
-          .type(`${headerPrefix2} ${noteText2}`)
-      })
+      cy.get('.monaco-editor .view-line:last')
+        .click({force: true})
+        .focused()
+        .type(`${headerPrefix2} ${noteText2}`, {force: true, delay: 1})
       cy.getByTestID('note-editor--preview').contains(noteText2)
       cy.getByTestID('note-editor--preview').should(
         'not.contain',

cypress/e2e/shared/tasks.test.ts

@@ -77,9 +77,11 @@ http.post(url: "https://foo.bar/baz", data: bytes(v: "body"))`
     cy.getByTestID('task-card-cron-btn').click()
     cy.getByTestID('task-form-schedule-input')
       .click()
+      .clear()
       .type('0 4 8-14 * *')
     cy.getByTestID('task-form-offset-input')
       .click()
+      .clear()
       .type('10m')
 
     cy.getByTestID('task-save-btn').click()
@@ -124,9 +126,11 @@ http.post(url: "https://foo.bar/baz", data: bytes(v: "body"))`
       .then(() => {
         cy.getByTestID('task-form-schedule-input')
           .click()
+          .clear()
           .type('24h')
         cy.getByTestID('task-form-offset-input')
           .click()
+          .clear()
           .type('20m')
       })
 

src/flows/pipes/Schedule/ExportTaskButton.tsx

@@ -64,6 +64,13 @@ const ExportTaskButton: FC<Props> = ({
             status: 'inactive',
           },
         })
+      } else if ((data?.task ?? []).length) {
+        patchTask({
+          taskID: data.task[0].id,
+          data: {
+            status: 'inactive',
+          },
+        })
       }
 
       postTask({data: {orgID: org.id, flux: query}})

src/flows/pipes/Schedule/History.tsx

@@ -25,6 +25,10 @@ import {PopupContext} from 'src/flows/context/popup'
 
 import {event} from 'src/cloud/utils/reporting'
 
+interface ListProps {
+  tasks: Task[]
+}
+
 interface Props {
   task: Task
 }
@@ -292,9 +296,11 @@ const History: FC<Props> = ({task}) => {
   )
 }
 
-const WrappedHistory: FC<Props> = ({task}) => (
+const WrappedHistory: FC<ListProps> = ({tasks}) => (
   <ErrorBoundary>
-    <History task={task} />
+    {tasks.map(task => (
+      <History key={task.id} task={task} />
+    ))}
   </ErrorBoundary>
 )
 export default WrappedHistory

src/flows/pipes/Schedule/view.tsx

@@ -229,7 +229,13 @@ const Schedule: FC<PipeProp> = ({Context}) => {
     return format_from_js_file(ast)
   }, [queryText, data.interval, data.offset])
   const hasChanges = useMemo(() => {
-    return taskText !== data?.task?.flux
+    if (data.task?.id) {
+      return taskText !== data.task.flux
+    }
+    if (data.task.length) {
+      return taskText !== data.task[0].flux
+    }
+    return false
   }, [taskText, data?.task?.flux])
 
   const updateInterval = evt => {
@@ -274,12 +280,14 @@ const Schedule: FC<PipeProp> = ({Context}) => {
   }, [taskText])
 
   const storeTask = (task: any) => {
+    const list = ((data.task.id ? [data.task] : data.task) || []).slice(0)
+    list.unshift({
+      id: task.id,
+      name: task.name,
+      flux: task.flux,
+    })
     update({
-      task: {
-        id: task.id,
-        name: task.name,
-        flux: task.flux,
-      },
+      task: list,
     })
   }
 
@@ -294,7 +302,7 @@ const Schedule: FC<PipeProp> = ({Context}) => {
         actions: [
           {
             title: 'View Run History',
-            menu: <History task={data.task} />,
+            menu: <History tasks={data.task.id ? data.task : data.task} />,
           },
         ],
       },