Run dbt cloud task as a part of pipeline

src/components/DBT/CreateOrgTaskForm.tsx

@@ -5,7 +5,7 @@
 import CustomDialog from '../Dialog/CustomDialog';
 import { Controller, useFieldArray, useForm } from 'react-hook-form';
 import Input from '../UI/Input/Input';
-import { TASK_GITPULL, TASK_DBTCLEAN, TASK_DOCSGENERATE } from '@/config/constant';
+import { TASK_GITPULL, TASK_DBTCLEAN, TASK_DBTCLOUD_JOB } from '@/config/constant';
 import { useSession } from 'next-auth/react';
 import { useContext, useEffect, useRef, useState } from 'react';
 import { httpGet, httpPost } from '@/helpers/http';
@@ -89,7 +89,8 @@
           .map((task: MasterTask) => {
             return { id: task.slug, label: task.slug };
           });
-        setMasterTasks(tasksDropDownRows);
+        console.log(tasksDropDownRows, 'taskdropdown');
+        setMasterTasks([...tasksDropDownRows]);
       } catch (err: any) {
         console.error(err);
         errorToast(err.message, [], globalContext);
@@ -155,6 +156,8 @@
     setLoading(false);
   };
 
+  const isDbtCloudTask = () => selectedTask?.id === TASK_DBTCLOUD_JOB;
+
   const FormContent = () => {
     return (
       <>
@@ -285,12 +288,13 @@
               </Button>
             </List>
           </Box>
-
           <Box sx={{ m: 2 }} />
+        </Box>
+        {!isDbtCloudTask() && (
           <InputLabel>
             <Command task={selectedTask} flags={selectedFlags} options={optionsRef} />
           </InputLabel>
-        </Box>
+        )}
       </>
     );
   };

src/components/DBT/DBTTaskList.tsx

@@ -242,6 +242,14 @@ export const DBTTaskList = ({
       const tempRows = tasks
         .filter((task: TransformTask) => task.slug != TASK_DOCSGENERATE)
         .map((task: TransformTask) => [
+          <Box
+            key={`label-${task.uuid}`}
+            sx={{ display: 'flex', alignItems: 'center', marginLeft: '10px' }}
+          >
+            <Typography variant="body2" fontWeight={400}>
+              {task.label}
+            </Typography>
+          </Box>,
           <Box
             key={`name-${task.uuid}`}
             sx={{ display: 'flex', alignItems: 'center', marginLeft: '10px' }}
@@ -338,7 +346,7 @@ export const DBTTaskList = ({
         hasCreatePermission={permissions.includes('can_create_orgtask')}
         openDialog={handleCreateOpenOrgTaskDialog}
         title="Task"
-        headers={{ values: ['Command'] }}
+        headers={{ values: ['Label', 'Command'] }}
         rows={rows}
         height={80}
       />

src/components/Flows/FlowCreate.tsx

@@ -168,12 +168,12 @@ const FlowCreate = ({
         setLoading(true);
         try {
           const data: any = await httpGet(session, `prefect/v1/flows/${flowId}`);
-
           let tasksToApply = tasks.filter(ValidateDefaultTasksToApplyInPipeline);
 
           if (data.transformTasks.length === 0) {
             tasksToApply = [];
           }
+
           //if "data.transformTasks" and "tasksToApply" are same then the alignment is simple else advanced.
           const ifTasksAligned = data.transformTasks.every(
             (task: { uuid: string; seq: number }, index: number) =>

src/components/Flows/TaskSequence.tsx

@@ -99,7 +99,9 @@ export const TaskSequence = ({ field, options: initialOptions }: TaskSequencePro
         >
           {node.rowIndex + 1}
         </Box>
-        <Box sx={{ p: '4px 12px', background: '#F5FAFA', width: '100%' }}>{node.data.command}</Box>
+        <Box sx={{ p: '4px 12px', background: '#F5FAFA', width: '100%' }}>
+          {node.data.command || node.data.slug.replace(/-/g, ' ')}
+        </Box>
         <Box
           sx={{
             p: '4px 12px',
@@ -157,7 +159,7 @@ export const TaskSequence = ({ field, options: initialOptions }: TaskSequencePro
       <Autocomplete
         data-testid="tasksequence"
         inputValue=""
-        getOptionLabel={(task: any) => task.command}
+        getOptionLabel={(task: any) => task.command || task.slug?.replace(/-/g, ' ')}
         placeholder="Select"
         options={autocompleteOptions}
         onChange={handleSelect}

src/config/constant.ts

@@ -24,6 +24,7 @@ export const TASK_DBTCLEAN = 'dbt-clean';
 export const TASK_DBTDEPS = 'dbt-deps';
 export const TASK_GITPULL = 'git-pull';
 export const TASK_DOCSGENERATE = 'dbt-docs-generate';
+export const TASK_DBTCLOUD_JOB = 'dbt-cloud-job';
 
 // Demo account
 export const demoAccDestSchema = process.env.NEXT_PUBLIC_DEMO_ACCOUNT_DEST_SCHEMA;